wn/Mqtt2Mongo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix mqtt topic

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2016-07-03 22:40:56 +02:00
parent ea4b765e85
commit 887b4f4abf
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
RePublisher.py
View File

@ -34,7 +34,12 @@ class RePublisher(threading.Thread):
del dataBlock['decodedTelegram'] del dataBlock['decodedTelegram']
if 'telegram' in dataBlock: if 'telegram' in dataBlock:
del dataBlock['telegram'] del dataBlock['telegram']
client.publish("IoT/ParsedData", json.dumps(msg, cls=MyEncoder)) metadataBlock = msg['metadata']
if 'Slave' in metadataBlock:
if metadataBlock['Slave'] == 'Thermometer' and metadataBlock['device'] == 'ModbusHub':
metadataBlock['name'] = 'FridgeThermometer'
topic = "IoT/ParsedData/%s" % metadataBlock['name']
client.publish(topic, json.dumps(msg, cls=MyEncoder))
Logger.log("RePublisher has sent data") Logger.log("RePublisher has sent data")
except Exception, e: except Exception, e:
Logger.log("Unexcepted exception %s in RePublisher: %s" % (e.__class__.__name__, str(e))) Logger.log("Unexcepted exception %s in RePublisher: %s" % (e.__class__.__name__, str(e)))