fixed missing topic

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(json.dumps({"thing": thing_uuid}))
+    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing": 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(json.dumps({"thing": thing_uuid}))
+    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing": thing_uuid}))
 
 
 if __name__ == "__main__":

cron/scripts/ext_api_sync/mqtt.py

@@ -6,7 +6,6 @@ import paho.mqtt.publish
 try:
     _broker = os.environ["MQTT_BROKER"]
     mqtt_setting = {
-        "topic": os.environ["MQTT_TOPIC"],
         "qos": int(os.environ["MQTT_QOS"]),
         "hostname": _broker.split(":")[0],
         "port": int(_broker.split(":")[1]),
@@ -20,8 +19,8 @@ except KeyError as e:
     raise EnvironmentError(f"Missing environment variable {e}")
 
 
-def send_mqtt_info(payload: str):
+def send_mqtt_info(topic, payload: str):
     """
     Publish a single mqtt message to a broker, then disconnect cleanly.
     """
-    paho.mqtt.publish.single(**mqtt_setting, payload=payload)
+    paho.mqtt.publish.single(**mqtt_setting, topic=topic, payload=payload)

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(json.dumps({"thing": thing_uuid}))
+    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing": 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(json.dumps({"thing": thing_uuid}))
+    mqtt.send_mqtt_info("data_parsed", json.dumps({"thing": thing_uuid}))
 
 
 if __name__ == "__main__":