From df455e9164011098b8c664bd86dd63f421d41c1d Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Thu, 8 Aug 2024 14:23:29 +0000
Subject: [PATCH] Telemetry Backend Service
- GenerateRawMetrics() add
---
.../backend/service/TelemetryBackendService.py | 18 +++++++++++++++++-
1 file changed, 17 insertions(+), 1 deletion(-)
diff --git a/src/telemetry/backend/service/TelemetryBackendService.py b/src/telemetry/backend/service/TelemetryBackendService.py
index 937409d15..048474d93 100755
--- a/src/telemetry/backend/service/TelemetryBackendService.py
+++ b/src/telemetry/backend/service/TelemetryBackendService.py
@@ -119,7 +119,7 @@ class TelemetryBackendService:
def GenerateCollectorResponse(self, collector_id: str, kpi_id: str, measured_kpi_value: Any):
"""
- Method to write response on Kafka topic
+ Method to write kpi value on RESPONSE Kafka topic
"""
producer = self.kafka_producer
kpi_value : Dict = {
@@ -134,6 +134,22 @@ class TelemetryBackendService:
)
producer.flush()
+ def GenerateRawMetric(self, metrics: Any):
+ """
+ Method writes raw metrics on VALUE Kafka topic
+ """
+ producer = self.kafka_producer
+ some_metric : Dict = {
+ "some_id" : metrics
+ }
+ producer.produce(
+ KafkaTopic.VALUE.value,
+ key = 'raw',
+ value = json.dumps(some_metric),
+ callback = self.delivery_callback
+ )
+ producer.flush()
+
def delivery_callback(self, err, msg):
"""
Callback function to handle message delivery status.
--
GitLab