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

config

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2017-11-13 14:13:53 +00:00
parent e767b9f8a6
commit c445edf5c2
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ModbusParser.py
View File

@ -10,7 +10,7 @@ class ModbusParser(AbstractParser, AbstractNextStage):
self.topic = "IoT/Measurement/ModbusHub"
def execute(self, data):
Logger.log("ModbusParser %s %s" % (type(data), str(data)))
#Logger.log("ModbusParser %s %s" % (type(data), str(data)))
try:
j = json.loads(data['payload'])

10
MqttDispatcher.py
View File

@ -18,16 +18,16 @@ BACKGROUND = False
PID_FILE = "/tmp/MqttDispatcher.pid"
LOG_FILE = "/tmp/MqttDispatcher.log"
MQTT_CONFIG = {
'host':'eupenstrasse20.dynamic.hottis.de',
'port':8883,
'tls':True,
'host':'localhost',
'port':1883,
'tls':False,
'ca':'ca.crt',
'user':'tron',
'password':'geheim123'
}
DATABASE_CONFIG = {
'period':300,
'host':'localhost',
'host':'172.16.2.17',
'user':'smarthome',
'password':'smarthome123',
'db':'smarthome'
@ -68,7 +68,7 @@ try:
Logger.log("MBusParser started ...")
modbusParser = ModbusParser()
#mqttReader.registerParser(modbusParser)
mqttReader.registerParser(modbusParser)
Logger.log("ModbusParser started ...")
persistentQueue = PersistentQueue()