From 974e37515925c7121be64bf9705c968bbbcb868e Mon Sep 17 00:00:00 2001
From: granseef <florian.gransee@ufz.de>
Date: Tue, 28 Jan 2025 14:28:31 +0100
Subject: [PATCH] add send_mqtt_info
---
cron/scripts/ext_api_sync/uba_api_sync.py | 19 +++++++++++--------
1 file changed, 11 insertions(+), 8 deletions(-)
diff --git a/cron/scripts/ext_api_sync/uba_api_sync.py b/cron/scripts/ext_api_sync/uba_api_sync.py
index fcbe3a45..55b40770 100644
--- a/cron/scripts/ext_api_sync/uba_api_sync.py
+++ b/cron/scripts/ext_api_sync/uba_api_sync.py
@@ -7,6 +7,7 @@ import os
import logging
import json
import click
+import mqtt
from datetime import datetime, timedelta
@@ -248,19 +249,21 @@ def main(thing_uuid, parameters, target_uri):
parsed_measure_data = parse_measure_data(measure_data, params["station_id"])
parsed_aqi_data = parse_aqi_data(aqi_data, params["station_id"])
parsed_observations = {"observations": parsed_measure_data + parsed_aqi_data}
- req = requests.post(
+ resp = requests.post(
f"{api_base_url}/observations/upsert/{thing_uuid}",
json=parsed_observations,
headers={"Content-type": "application/json"},
)
- if req.status_code == 201:
- logging.info(
- f"Successfully inserted {len(parsed_observations['observations'])} "
- f"observations for thing {thing_uuid} from UBA API into TimeIO DB"
- )
- else:
- logging.error(f"{req.text}")
+ if resp.status_code != 201:
+ logging.error(f"{resp.text}")
+ resp.raise_for_status()
+ # exit
+ logging.info(
+ f"Successfully inserted {len(parsed_observations['observations'])} "
+ f"observations for thing {thing_uuid} from UBA API into TimeIO DB"
+ )
+ mqtt.send_mqtt_info("data_parsed", json.dumps({"thing_uuid": thing_uuid}))
if __name__ == "__main__":
main()
--
GitLab