gitea_admin/sientia-dataops-laborious_temporal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SIENTIAPDE-1169

Browse Source 
Update OPC metrics to include opc_server_id for enhanced tracking
This commit is contained in:
vitor-aignosi
2025-08-18 14:15:22 -03:00
parent 366d406689
commit e567b8d0a7
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
laborious/metrics.py
View File

@@ -30,12 +30,12 @@ PREDICTION_RESPONSE_TIME_MONITOR = Histogram(
PREDICTION_OPC_WRITING_COUNT = Counter( PREDICTION_OPC_WRITING_COUNT = Counter(
"laborious_prediction_opc_writing_count", "laborious_prediction_opc_writing_count",
"Number of predictions written to the OPC server", "Number of predictions written to the OPC server",
CORE_LABELS, [CORE_LABELS, "opc_server_id"],
) )
PREDICTION_OPC_WRITING_RESPONSE_TIME_MONITOR = Histogram( PREDICTION_OPC_WRITING_RESPONSE_TIME_MONITOR = Histogram(
"laborious_prediction_opc_writing_response_time_monitor", "laborious_prediction_opc_writing_response_time_monitor",
"Current response time of each prediction written to the OPC server", "Current response time of each prediction written to the OPC server",
CORE_LABELS, [CORE_LABELS, "opc_server_id"],
buckets=[0.01, 0.05, 0.1, 0.2, 0.5, 1.0, 2.0, 5.0, 10.0] buckets=[0.01, 0.05, 0.1, 0.2, 0.5, 1.0, 2.0, 5.0, 10.0]
) )

6
laborious/utils/repository/opc_repository.py
View File

@@ -266,7 +266,8 @@ class OpcRepository():
metrics.PREDICTION_OPC_WRITING_COUNT.labels( metrics.PREDICTION_OPC_WRITING_COUNT.labels(
pod_id=self.pod_id, pod_id=self.pod_id,
model_name=metadata['model_name'], model_name=metadata['model_name'],
pipeline_name=metadata['workflow_name'] pipeline_name=metadata['workflow_name'],
opc_server_id=self.id
).inc() ).inc()
end_time = time.time() end_time = time.time()
@@ -274,7 +275,8 @@ class OpcRepository():
metrics.PREDICTION_OPC_WRITING_RESPONSE_TIME_MONITOR.labels( metrics.PREDICTION_OPC_WRITING_RESPONSE_TIME_MONITOR.labels(
pod_id=self.pod_id, pod_id=self.pod_id,
model_name=metadata['model_name'], model_name=metadata['model_name'],
pipeline_name=metadata['workflow_name'] pipeline_name=metadata['workflow_name'],
opc_server_id=self.id
).observe(response_time) ).observe(response_time)
except Exception as e: except Exception as e: