/usr/lib/python3.9/site-packages/glances/exports/__pycache__
a ���c� � @ s\ d Z ddlZddlmZ ddlmZ ddlmZ ddlm Z ddl m Z G dd � d e�Z dS ) z0InfluxDB (up to InfluxDB 1.7.x) interface class.� N)�node)�logger)� GlancesExport)�InfluxDBClient)�InfluxDBClientErrorc s: e Zd ZdZd � fdd� Zdd� Zdd� Zd d � Z� ZS ) �Exportz.This class manages the InfluxDB export module.Nc s� t t| �j||d� d| _d| _d| _d| _d| _d| _d| _ | j dg d�g d�d�| _ | j sft d� t � �d �d | _ | �� | _dS ) z Init the InfluxDB export IF.)�config�argsN�http�influxdb)�host�port�user�password�db)�protocol�prefix�tags)Z mandatories�optionsz!Missing INFLUXDB version 1 config�.r )�superr �__init__r r r r r r �hostnameZ load_conf� export_enable�exitr �split�init�client)�selfr r �� __class__� �D/usr/lib/python3.9/site-packages/glances/exports/glances_influxdb.pyr s �zExport.__init__c C s� | j s dS | jdur(| j�� dkr(d}nd}z6t| j| j|d| j| j| jd�}dd� |� � D �}W nB t y� } z*t � d| j|f � t �d � W Y d}~n d}~0 0 | j|v r�t �d �|j�� nt � d | j � t �d � |S ) z+Init the connection to the InfluxDB server.N�httpsTF)r r �sslZ verify_ssl�usernamer Zdatabasec S s g | ] }|d �qS )�namer! )�.0�ir! r! r" � <listcomp>J � z Export.init.<locals>.<listcomp>z-Cannot connect to InfluxDB database '%s' (%s)� z-Stats will be exported to InfluxDB server: {}z6InfluxDB database '%s' did not exist. Please create it)r r �lowerr r r r r r Zget_list_databaser r Zcritical�sysr �info�formatZ_baseurl)r r$ r Z get_all_db�er! r! r" r 5 s0 � z Export.initc s8 g }t t||��� dd� |D �}t|�dkr2dg}|D ]���durX� �fdd�� D �}n� }|D ]j}|| du rrq`zt|| �||< W q` ttfy� zt|| �||< W n ttfy� Y n0 Y q`0 q`| �| j�}d|v �r|d |v �rt||d �||d < |� |d � | j |d< |� |||d �� q6|S ) z`Normalize data for the InfluxDB's data model. :return: a list of measurements. c S s$ g | ] }|� d �r|�d�d �qS )z.keyr r )�endswithr �r' �kr! r! r" r) c r* z%Export._normalize.<locals>.<listcomp>r Nc s4 i | ],}|� d ����r|�d ���d�� | �qS )z{}.� )� startswithr/ �replacer2 �Z data_dict� measurementr! r" � <dictcomp>j s �z%Export._normalize.<locals>.<dictcomp>�keyr )r8 r �fields) �dict�zip�len�float� TypeError� ValueError�strZ parse_tagsr �popr �append) r r& �columns�points�retZ keys_listr; r3 r r! r7 r" � _normalizeW s8 � zExport._normalizec C s� | j dur| j d | }t|�dkr6t�d�|�� nfz | jj| �|||�dd� W n6 ty� } z t�d�||�� W Y d}~nd}~0 0 t�d�|�� dS ) z(Write the points to the InfluxDB server.Nr r z(Cannot export empty {} stats to InfluxDB�s)Ztime_precisionz'Cannot export {} stats to InfluxDB ({})zExport {} stats to InfluxDB) r r> r �debugr/ r Z write_pointsrH � Exception)r r& rE rF r0 r! r! r" �export� s (z Export.export)NN) �__name__� __module__� __qualname__�__doc__r r rH rL � __classcell__r! r! r r" r s "7r ) rP r- �platformr Zglances.loggerr Z glances.exports.glances_exportr r r Zinfluxdb.clientr r r! r! r! r" �<module> s
.
Edit
..
Edit
__init__.cpython-39.opt-1.pyc
Edit
__init__.cpython-39.pyc
Edit
glances_cassandra.cpython-39.opt-1.pyc
Edit
glances_cassandra.cpython-39.pyc
Edit
glances_couchdb.cpython-39.opt-1.pyc
Edit
glances_couchdb.cpython-39.pyc
Edit
glances_csv.cpython-39.opt-1.pyc
Edit
glances_csv.cpython-39.pyc
Edit
glances_elasticsearch.cpython-39.opt-1.pyc
Edit
glances_elasticsearch.cpython-39.pyc
Edit
glances_export.cpython-39.opt-1.pyc
Edit
glances_export.cpython-39.pyc
Edit
glances_graph.cpython-39.opt-1.pyc
Edit
glances_graph.cpython-39.pyc
Edit
glances_graphite.cpython-39.opt-1.pyc
Edit
glances_graphite.cpython-39.pyc
Edit
glances_influxdb.cpython-39.opt-1.pyc
Edit
glances_influxdb.cpython-39.pyc
Edit
glances_influxdb2.cpython-39.opt-1.pyc
Edit
glances_influxdb2.cpython-39.pyc
Edit
glances_json.cpython-39.opt-1.pyc
Edit
glances_json.cpython-39.pyc
Edit
glances_kafka.cpython-39.opt-1.pyc
Edit
glances_kafka.cpython-39.pyc
Edit
glances_mqtt.cpython-39.opt-1.pyc
Edit
glances_mqtt.cpython-39.pyc
Edit
glances_opentsdb.cpython-39.opt-1.pyc
Edit
glances_opentsdb.cpython-39.pyc
Edit
glances_prometheus.cpython-39.opt-1.pyc
Edit
glances_prometheus.cpython-39.pyc
Edit
glances_rabbitmq.cpython-39.opt-1.pyc
Edit
glances_rabbitmq.cpython-39.pyc
Edit
glances_restful.cpython-39.opt-1.pyc
Edit
glances_restful.cpython-39.pyc
Edit
glances_riemann.cpython-39.opt-1.pyc
Edit
glances_riemann.cpython-39.pyc
Edit
glances_statsd.cpython-39.opt-1.pyc
Edit
glances_statsd.cpython-39.pyc
Edit
glances_zeromq.cpython-39.opt-1.pyc
Edit
glances_zeromq.cpython-39.pyc
Edit