diff --git a/.vscode/settings.json b/.vscode/settings.json new file mode 100644 index 0000000..cee4243 --- /dev/null +++ b/.vscode/settings.json @@ -0,0 +1,3 @@ +{ + "iis.configDir": "" +} \ No newline at end of file diff --git a/Mqtt2ThingBoardGateWay.py b/Mqtt2ThingBoardGateWay.py index 80da9fe..b9cd6dd 100644 --- a/Mqtt2ThingBoardGateWay.py +++ b/Mqtt2ThingBoardGateWay.py @@ -16,6 +16,7 @@ class Mqtt2ThingBoard: tb_gateway_user = "K9iW4T5E7tVeP4ZyapxB" tb_port = 1883 tb_client = mqtt.Client(tb_gateway_user) + tb_client.username_pw_set(tb_gateway_user,None) #Sent MQTT Debugging Message def publishDebugMsg(self,msg): @@ -24,9 +25,9 @@ class Mqtt2ThingBoard: #Sent message to MQTT telemetry def publishTelemetryMsg(self,msg): + print(msg) self.tb_client.publish("v1/gateway/telemetry",msg,0,True) - - + #react to MQTT scenario requests: def onMqttMessage(self, client, userdata, message): @@ -53,17 +54,24 @@ class Mqtt2ThingBoard: #set up the system: login to MQTT + get all needed data from the BSH def __init__(self): self.publishDebugMsg("Connecting to MQTT Server") - self.mqtt_client.connect(self.host_name,self.host_port) + ret1 = self.mqtt_client.connect(self.host_name,self.host_port) self.publishDebugMsg("Connecting to ThingsBoard Mqtt Gateway") - self.tb_client.connect(self.host_name,self.tb_port) + ret2 = self.tb_client.connect(self.host_name,self.tb_port) self.publishDebugMsg("Setting up the Environment...") self.publishDebugMsg("Subscribe to MQTT Messages") self.subscribeToMqttInputs() - self.publishTelemetryMsg("{\"TempSensorBuero\":[{\"temperature\":11.8}]}") + msg = { + 'TempSensorBuero': [ + { + 'temperature': 33.8 + } + ] + } + self.publishTelemetryMsg(json.dumps(msg)) def loop(self): @@ -76,4 +84,3 @@ class Mqtt2ThingBoard: Mqtt2ThingBoardGateWay = Mqtt2ThingBoard() -Mqtt2ThingBoardGateWay.loop()