Merge pull request #17 from City-of-Helsinki/feature/add-device-id-to…

…-kafka-raw-data add extracted device id to kafka raw data topic
City-of-Helsinki · Oct 17, 2023 · 1fe8d90 · 1fe8d90
2 parents e71bd8f + 5693562
commit 1fe8d90
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/app.py b/app.py
@@ -110,6 +110,8 @@ async def api_v2(request: Request, endpoint: dict) -> Response:
     )
     response_message = str(response_message)
     print("REMOVE ME", auth_ok, device_id, topic_name, response_message, status_code)
+    # add extracted device id to request data before pushing to kafka raw data topic
+    request_data["device_id"] = device_id
     # We assume device data is valid here
     logging.debug(pprint.pformat(request_data))
     if auth_ok and topic_name:

diff --git a/tests/test_api2.py b/tests/test_api2.py
@@ -1,7 +1,6 @@
 import logging
 import os
 from datetime import datetime, timedelta, timezone
-
 import httpx
 
 logging.basicConfig(level=logging.INFO)