nils/Mqtt2ThingsBoard
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

first running version

Browse Source
This commit is contained in:
NilsGrunwald
2023-08-28 17:59:29 +02:00
parent c8a835cdae
commit 8e11c2a992
2 changed files with 16 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
.vscode/settings.json vendored Normal file
View File

@@ -0,0 +1,3 @@
{
"iis.configDir": ""
}

19
Mqtt2ThingBoardGateWay.py
View File

@@ -16,6 +16,7 @@ class Mqtt2ThingBoard:
tb_gateway_user = "K9iW4T5E7tVeP4ZyapxB" tb_gateway_user = "K9iW4T5E7tVeP4ZyapxB"
tb_port = 1883 tb_port = 1883
tb_client = mqtt.Client(tb_gateway_user) tb_client = mqtt.Client(tb_gateway_user)
tb_client.username_pw_set(tb_gateway_user,None)
#Sent MQTT Debugging Message #Sent MQTT Debugging Message
def publishDebugMsg(self,msg): def publishDebugMsg(self,msg):
@@ -24,9 +25,9 @@ class Mqtt2ThingBoard:
#Sent message to MQTT telemetry #Sent message to MQTT telemetry
def publishTelemetryMsg(self,msg): def publishTelemetryMsg(self,msg):
print(msg)
self.tb_client.publish("v1/gateway/telemetry",msg,0,True) self.tb_client.publish("v1/gateway/telemetry",msg,0,True)
#react to MQTT scenario requests: #react to MQTT scenario requests:
def onMqttMessage(self, client, userdata, message): 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 #set up the system: login to MQTT + get all needed data from the BSH
def __init__(self): def __init__(self):
self.publishDebugMsg("Connecting to MQTT Server") 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.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("Setting up the Environment...")
self.publishDebugMsg("Subscribe to MQTT Messages") self.publishDebugMsg("Subscribe to MQTT Messages")
self.subscribeToMqttInputs() self.subscribeToMqttInputs()
self.publishTelemetryMsg("{\"TempSensorBuero\":[{\"temperature\":11.8}]}") msg = {
'TempSensorBuero': [
{
'temperature': 33.8
}
]
}
self.publishTelemetryMsg(json.dumps(msg))
def loop(self): def loop(self):
@@ -76,4 +84,3 @@ class Mqtt2ThingBoard:
Mqtt2ThingBoardGateWay = Mqtt2ThingBoard() Mqtt2ThingBoardGateWay = Mqtt2ThingBoard()
Mqtt2ThingBoardGateWay.loop()