o va @sXdZddlZddlmZddlmZddlmZddlm Z ddl Z Gddde Z dS) zOpenTSDB interface class.N)Number)range)logger) GlancesExportcs>eZdZdZd fdd ZddZddZfd d ZZS) Exportz.This class manages the OpenTSDB export module.Ncshtt|j||dd|_d|_|jdddgddgd|_|js%td |jdur-d |_| |_ dS) zInit the OpenTSDB export IF.)configargsNZopentsdbhostportprefixtags)Z mandatoriesoptionsZglances) superr__init__r r Z load_conf export_enablesysexitinitclient)selfrr __class__B/usr/lib/python3/dist-packages/glances/exports/glances_opentsdb.pyr$s  zExport.__init__c Csr|jsdSztj|jt|jdd}W|Sty8}ztd|j|j|ft dWYd}~|Sd}~ww)z+Init the connection to the OpenTSDB server.NT)r Z check_hostz,Cannot connect to OpenTSDB server %s:%s (%s)r) rpotsdbZClientr intr ExceptionrZcriticalrr)rZdberrrr=sz Export.initc Cstt|D]F}t||tsqd|j|||}||}||j}z |jj ||fi|Wqt yL}zt d||fWYd}~qd}~wwt d|dS)z&Export the stats to the Statsd server.z{}.{}.{}z(Can not export stats %s to OpenTSDB (%s)NzExport {} stats to OpenTSDB)rlen isinstancerformatr Z parse_tagsr rsendrrerrordebug) rnamecolumnsZpointsiZ stat_nameZ stat_valuer rrrrexportLs z Export.exportcs|jtt|dS)z!Close the OpenTSDB export module.N)rwaitrrr)rrrrrZs z Export.exit)NN) __name__ __module__ __qualname____doc__rrr(r __classcell__rrrrr s r) r-rZnumbersrZglances.compatrZglances.loggerrZglances.exports.glances_exportrrrrrrrs