telemetry values as seperate keys in mqtt

EricAndrechek · Apr 10, 2024 · 003c59f · 003c59f
1 parent d23c434
commit 003c59f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/tracking-dashboard/backend/mqtt-syncer.py b/tracking-dashboard/backend/mqtt-syncer.py
@@ -185,7 +185,9 @@ def on_message(client, userdata, message):
                             print("No change in lat, lon, or alt")
                             # send telemetry data to mqtt
                             if 'telemetry' in src['data']:
-                                client.publish("TELEMETRY/" + message_building[id]['name'] + "-" + str(message_building[id]['ssid']), json.dumps(src['data']['telemetry']), retain=True, qos=0)
+                                topic = "TELEMETRY/" + message_building[id]['name'] + "-" + str(message_building[id]['ssid'])
+                                for key in src['data']['telemetry']:
+                                    client.publish(topic + "/" + key, json.dumps(src['data']['telemetry'][key]), retain=True, qos=0)
                                 print("Telemetry sent")
                             else:
                                 print("No telemetry data")

diff --git a/tracking-dashboard/backend/tasks/mqttadder.py b/tracking-dashboard/backend/tasks/mqttadder.py
@@ -14,7 +14,8 @@ def add_data_task(data_type, data):
     if data_type == "position":
         client.publish("POSITION/" + data["name"], json.dumps(data), retain=True, qos=0, properties=properties)
     elif data_type == "telemetry":
-        client.publish("TELEMETRY/" + data["name"], json.dumps(data), retain=True, qos=0, properties=properties)
+        for key in data:
+            client.publish("TELEMETRY/" + key, json.dumps(data[key]), retain=True, qos=0, properties=properties)
 
     client.disconnect()