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

name in monitor message

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2016-12-21 12:47:14 +01:00
parent 6d415e481c
commit 6884d44bb8
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
MonitorPublisher.py
View File

@ -53,7 +53,7 @@ class MonitorPublisher(threading.Thread):
self.nameMap[name]['cnt'] = 0; self.nameMap[name]['cnt'] = 0;
self.nameMap[name]['oldbody'] = self.nameMap[name]['body'] self.nameMap[name]['oldbody'] = self.nameMap[name]['body']
message = str(self.nameMap[name]['slot']) + " " + self.nameMap[name]['header'] + " " + self.nameMap[name]['body'] message = str(self.nameMap[name]['slot']) + " " + self.nameMap[name]['header'] + " " + self.nameMap[name]['body']
client.publish("IoT/Monitor/Message", message, retain=True) client.publish("IoT/Monitor/Message/" + name, message, retain=True)
Logger.log("MonitorPublisher has sent: " + message) Logger.log("MonitorPublisher has sent: " + message)
else: else:
self.nameMap[name]['cnt'] += 1 self.nameMap[name]['cnt'] += 1

4
mqtt2mongo.py
View File

@ -18,8 +18,8 @@ from logger import Logger
import time import time
DEBUG = True DEBUG = True
DEBUG_TO_STDOUT = False DEBUG_TO_STDOUT = True
BACKGROUND = True BACKGROUND = False
PID_FILE = "/opt/logs/mqtt2mongo.pid" PID_FILE = "/opt/logs/mqtt2mongo.pid"
LOG_FILE = "/opt/logs/mqtt2mongo.log" LOG_FILE = "/opt/logs/mqtt2mongo.log"
MQTT_BROKER = "127.0.0.1" MQTT_BROKER = "127.0.0.1"