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