From 254be06004a4196c64a383268b4b00795ea5b485 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Wed, 5 Nov 2025 12:38:35 -0300 Subject: [PATCH] SIENTIAPDE-1325 Update requirements.txt to use version 1.5.3 of sientia-dataops-library and enhance DataManager and ResourceManager with improved logging and timestamping for data insertion and retrieval. --- ingestor/managers/data_manager.py | 6 +++++- ingestor/managers/resource_manager.py | 6 +++++- requirements.txt | 2 +- 3 files changed, 11 insertions(+), 3 deletions(-) diff --git a/ingestor/managers/data_manager.py b/ingestor/managers/data_manager.py index a493aa2..3f6d998 100644 --- a/ingestor/managers/data_manager.py +++ b/ingestor/managers/data_manager.py @@ -11,6 +11,7 @@ from sientia_do.observability.logger import Logger from sientia_do.observability.metrics_controller import MetricsController from sientia_do.observability.sientia_monitoring import SientiaMonitoring from sientia_do.repository.mongodb_repository import MongoDBRepository +from sientia_do.temporal.constants import now import ingestor.metrics as metrics @@ -260,7 +261,10 @@ class DataManager(SientiaMonitoring): try: await self.mongo_repository.insert( collection_name=topic, - document=data, + document={ + **data, + 'inserted_at': now() + }, metadata=self.metadata, ) self.logger.debug(f'Message inserted into MongoDB collection {topic}: {data}') diff --git a/ingestor/managers/resource_manager.py b/ingestor/managers/resource_manager.py index d6273e4..50cbc17 100644 --- a/ingestor/managers/resource_manager.py +++ b/ingestor/managers/resource_manager.py @@ -121,7 +121,11 @@ class ResourceManager(SientiaMonitoring): and delegates to the get() method for the actual Redis operation. """ - return await self.redis_repository.get(f'slot:opc_tags:{tag_id}', metadata=self.metadata) + self.info(f'Getting tag slot for tag_id: {tag_id}', metadata=self.metadata) + + slot = await self.redis_repository.get(f'slot:opc_tags:{tag_id}', metadata=self.metadata) + self.info(f'Tag slot for tag_id: {tag_id} is: {slot}', metadata=self.metadata) + return slot async def ingestor_heartbeat(self) -> None: """ diff --git a/requirements.txt b/requirements.txt index be908bf..bb176bf 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,5 +1,5 @@ asyncua==1.1.5 redis -git+ssh://git@github.com/Aignosi/sientia-dataops-library.git@1.5.2 +git+ssh://git@github.com/Aignosi/sientia-dataops-library.git@1.5.3 prometheus_client pymongo \ No newline at end of file