From 9f045b898f60b59a1945828cfd1f119d1cbbec3a Mon Sep 17 00:00:00 2001 From: BogPin Date: Thu, 11 Apr 2024 21:34:04 +0300 Subject: [PATCH 1/2] Lab3 --- agent/docker/mosquitto/data/mosquitto.db | Bin 0 -> 3103 bytes agent/docker/mosquitto/log/mosquitto.log | 23 +++++++++++++++++++++++ hub/app/adapters/store_api_adapter.py | 12 ++++++++++++ 3 files changed, 35 insertions(+) create mode 100644 agent/docker/mosquitto/data/mosquitto.db create mode 100644 agent/docker/mosquitto/log/mosquitto.log diff --git a/agent/docker/mosquitto/data/mosquitto.db b/agent/docker/mosquitto/data/mosquitto.db new file mode 100644 index 0000000000000000000000000000000000000000..0fb48b8769a59d70e0bbdef7f7a627b69ab1baa4 GIT binary patch literal 3103 zcmb7`NpI6Y6vxw2Hi-l30SOQgN?9(9$K!PX6aaziC_I}x#n zsT#VG(yH&}w3*SguIsqoy4zB1Vwk3?rNp^+a^j9WaiB}XTonb%!dp3IS1|?j5R6Ss zb)4!s^F}1`9P_q6Pl9~;ZWuN$rYTbiF*KcZ=jpG$7I7Oni?xIQ#DPZ3HZWmdaN@~V zA`t}c%oFp%Y#lHQFGUOp+atvc1lfHDt1m>-RvsT~LdM!bqcv1sifZ^?$1ru%z{phD z7d*uJb2(8++7J=cB~(HU+agFaQ)=~@NZrid@pd2|aZCk!`9MgSL?=iEbL&s##KR+r zS*5CKVnl&@_KBQ2TS(2g3_=YP*_4IG6MF8k9C>6kQc!9j3O-dHiCA#HT!mxn9-@K zmVu0Zb>5Rhi>ov1dLonB$b^}!epgN`uFgI&r_;vBhIylMN2HGJxylDSwRMdkVx_fN zyDbNfNfU|yiMl|zPA>6zN=#kmqXVHI<1iP;*-$n>7&9R&xTJ^=}qyH!-RBPC-Q<$sPF(W!my{AugPJ;N*J#T zVc@K~kpNo!`E^)O{Cj*=d;sIYu$ccLhmBU11D%@sBB%l%_6ce4HAAQCF$;O3oS@f< zVAflj6gd!G@idyrd7?^%q%Ta!X~MQNoAexM?$2jwd_tm}w#U|T9$8!tZVU7r|1GBo s8%UruSV673fH?L`ju19xfQW*q(FVeaPambB?9N*S1ix{`^LxJW7i=>;2mk;8 literal 0 HcmV?d00001 diff --git a/agent/docker/mosquitto/log/mosquitto.log b/agent/docker/mosquitto/log/mosquitto.log new file mode 100644 index 00000000..1c77bdb9 --- /dev/null +++ b/agent/docker/mosquitto/log/mosquitto.log @@ -0,0 +1,23 @@ +1712845014: mosquitto version 2.0.18 starting +1712845014: Config loaded from /mosquitto/config/mosquitto.conf. +1712845014: Opening ipv4 listen socket on port 1883. +1712845014: Opening ipv6 listen socket on port 1883. +1712845014: mosquitto version 2.0.18 running +1712845015: New connection from 172.21.0.3:43041 on port 1883. +1712845015: New client connected from 172.21.0.3:43041 as auto-C22D77C5-D8C8-986D-F93B-421213BDA931 (p2, c1, k60). +1712845119: New connection from 172.21.0.4:33379 on port 1883. +1712845119: New client connected from 172.21.0.4:33379 as auto-CB8FA72B-2781-45A5-BFDF-02B2E320AF23 (p2, c1, k60). +1712845119: New connection from 172.21.0.5:55987 on port 1883. +1712845119: New connection from 172.21.0.5:53667 on port 1883. +1712845119: New client connected from 172.21.0.5:55987 as auto-0C7F60DE-47A8-818F-7D5F-E14008C42F7D (p2, c1, k60). +1712845119: New client connected from 172.21.0.5:53667 as auto-53959546-CAC4-3558-B898-11428FD007A2 (p2, c1, k60). +1712851448: Saving in-memory database to /mosquitto/data//mosquitto.db. +1712858179: New connection from 172.21.0.1:36738 on port 1883. +1712858179: New client connected from 172.21.0.1:36738 as mqtt-explorer-dad9df72 (p2, c1, k60). +1712858239: Client mqtt-explorer-dad9df72 disconnected. +1712858383: New connection from 172.21.0.1:40522 on port 1883. +1712858383: New client connected from 172.21.0.1:40522 as mqtt-explorer-6eee19ca (p2, c1, k60). +1712859918: Saving in-memory database to /mosquitto/data//mosquitto.db. +1712860393: Client auto-C22D77C5-D8C8-986D-F93B-421213BDA931 closed its connection. +1712860394: mosquitto version 2.0.18 terminating +1712860394: Saving in-memory database to /mosquitto/data//mosquitto.db. diff --git a/hub/app/adapters/store_api_adapter.py b/hub/app/adapters/store_api_adapter.py index cd76be46..0ca5c3d7 100644 --- a/hub/app/adapters/store_api_adapter.py +++ b/hub/app/adapters/store_api_adapter.py @@ -22,3 +22,15 @@ def save_data(self, processed_agent_data_batch: List[ProcessedAgentData]): bool: True if the data is successfully saved, False otherwise. """ # Implement it + url = f"{self.api_base_url}/processed_agent_data/" + data = [processed_agent_data.model_dump_json() for processed_agent_data in processed_agent_data_batch] + headers = {'Content-Type': 'application/json'} + try: + with requests.post(url, data=json.dumps(data), headers=headers) as response: + if response.status_code != 200: + logging.error(f"Invalid Hub response\nData: {data}\nResponse: {response}") + return False + except Exception as e: + logging.error(f"Error occurred during request: {e}") + return False + return True \ No newline at end of file From b9780bb521542d9cd202ca4ef291ab618745b3c9 Mon Sep 17 00:00:00 2001 From: BogPin Date: Sun, 8 Jun 2025 01:12:06 +0300 Subject: [PATCH 2/2] Lab3