luzifer/mqtt2influx
1
0
Fork 0
mirror of https://github.com/Luzifer/mqtt2influx.git synced 2024-10-18 05:44:19 +00:00
Code Issues Releases Wiki Activity

Allow overriding vars in env, add info on submit

Browse source 
Signed-off-by: Knut Ahlers <knut@ahlers.me>
This commit is contained in:
Knut Ahlers 2020-07-11 18:48:23 +02:00
parent c3c4a0913c
commit bb1a81005e
Signed by: luzifer
GPG key ID: DC2729FDD34BE99E
1 changed files with 9 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
main.py
View file

@ -55,6 +55,10 @@ class MQTT2InfluxDB():
)) ))
if len(points) > 0: if len(points) > 0:
logging.info('Submitting {n} datapoints for topic {topic}'.format(
n=len(points),
topic=msg.topic,
))
self.influx.submit(points) self.influx.submit(points)
def run(self): def run(self):
@ -66,19 +70,16 @@ class MQTT2InfluxDB():
mqtt_config = vault.read_data('secret/mqtt2influx/mqtt') mqtt_config = vault.read_data('secret/mqtt2influx/mqtt')
client.username_pw_set( client.username_pw_set(
self.obj_get(mqtt_config, 'user', self.obj_get( self.obj_get(os.environ, 'MQTT_USER', mqtt_config['user']),
os.environ, 'MQTT_USER')), self.obj_get(os.environ, 'MQTT_PASS', mqtt_config['pass']),
self.obj_get(mqtt_config, 'pass', self.obj_get(
os.environ, 'MQTT_PASS')),
) )
logging.debug('Connecting to MQTT broker...') logging.debug('Connecting to MQTT broker...')
client.connect( client.connect(
self.obj_get(mqtt_config, 'host', self.obj_get( self.obj_get(os.environ, 'MQTT_HOST', mqtt_config['host']),
os.environ, 'MQTT_HOST')), self.obj_get(os.environ, 'MQTT_HOST',
port=self.obj_get(mqtt_config, 'port', self.obj_get( self.obj_get(mqtt_config, 'host', 1883)),
os.environ, 'MQTT_PORT', 1883)),
keepalive=10, keepalive=10,
) )