Apply 4 suggestion(s) to 4 file(s)

cron/scripts/ext_api_sync/bosch_api_sync.py

@@ -109,7 +109,7 @@ def main(thing_uuid, parameters, target_uri):
         f"Successfully inserted {len(parsed_observations['observations'])} "
         f"observations for thing {thing_uuid} from Bosch API into TimeIO DB"
     )
-    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing": thing_uuid}))
+    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing_uuid": thing_uuid}))
 
 
 if __name__ == "__main__":

cron/scripts/ext_api_sync/dwd_api_sync.py

@@ -105,7 +105,7 @@ def main(thing_uuid, parameters, target_uri):
         f"Successfully inserted {len(parsed_observations['observations'])} "
         f"observations for thing {thing_uuid} from DWD API into TimeIO DB"
     )
-    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing": thing_uuid}))
+    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing_uuid": thing_uuid}))
 
 
 if __name__ == "__main__":

cron/scripts/ext_api_sync/nm_api_sync.py

@@ -126,7 +126,7 @@ def main(thing_uuid: str, parameters: str, target_uri: str):
         f"Successfully inserted {len(parsed_observations['observations'])} "
         f"observations for thing {thing_uuid} from NM API into TimeIO DB"
     )
-    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing": thing_uuid}))
+    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing_uuid": thing_uuid}))
 
 
 if __name__ == "__main__":

cron/scripts/ext_api_sync/ttn_api_sync.py

@@ -74,7 +74,7 @@ def main(thing_uuid: str, parameters: str, target_uri: str):
         f"Successfully inserted {len(post_data['observations'])} "
         f"observations for thing {thing_uuid} from TTN API into TimeIO DB"
     )
-    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing": thing_uuid}))
+    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing_uuid": thing_uuid}))
 
 
 if __name__ == "__main__":