From edcfa86f6557cc98ee1f3c7e2c2e0441498fc4b9 Mon Sep 17 00:00:00 2001 From: Wolfgang Hottgenroth Date: Fri, 10 Nov 2017 23:38:12 +0100 Subject: [PATCH] DatabasePreparer --- MqttReceiver.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/MqttReceiver.py b/MqttReceiver.py index 273043e..576da47 100644 --- a/MqttReceiver.py +++ b/MqttReceiver.py @@ -5,7 +5,7 @@ import json import datetime _parsers = {} - +_seenTopics = {} def on_message(client, userdata, msg): try: @@ -15,6 +15,9 @@ def on_message(client, userdata, msg): global _parsers _parsers[msg.topic].execute(j) + + global _seenTopics + _seenTopics[msg.topic] = datetime.datetime.now() except ValueError, e: Logger.log("Exception %s in MqttReceiver, on_message" % (str(e)))