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

DatabasePreparer

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2017-11-10 23:38:12 +01:00
parent 5be27e1994
commit edcfa86f65
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
MqttReceiver.py
View File

@ -5,7 +5,7 @@ import json
import datetime import datetime
_parsers = {} _parsers = {}
_seenTopics = {}
def on_message(client, userdata, msg): def on_message(client, userdata, msg):
try: try:
@ -15,6 +15,9 @@ def on_message(client, userdata, msg):
global _parsers global _parsers
_parsers[msg.topic].execute(j) _parsers[msg.topic].execute(j)
global _seenTopics
_seenTopics[msg.topic] = datetime.datetime.now()
except ValueError, e: except ValueError, e:
Logger.log("Exception %s in MqttReceiver, on_message" % (str(e))) Logger.log("Exception %s in MqttReceiver, on_message" % (str(e)))