diff --git a/ModbusParser.py b/ModbusParser.py index 34189f5..e4d3d99 100644 --- a/ModbusParser.py +++ b/ModbusParser.py @@ -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']) diff --git a/MqttDispatcher.py b/MqttDispatcher.py index 6569f3f..558acf3 100644 --- a/MqttDispatcher.py +++ b/MqttDispatcher.py @@ -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()