From 29e64a62290b3100b27e86aa03ab7f7da799479f Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Sat, 12 Oct 2024 15:26:51 +0000
Subject: [PATCH] Minor changes in Telemetry backend
---
.../backend/service/TelemetryBackendService.py | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
diff --git a/src/telemetry/backend/service/TelemetryBackendService.py b/src/telemetry/backend/service/TelemetryBackendService.py
index 8cef95292..ab4991690 100755
--- a/src/telemetry/backend/service/TelemetryBackendService.py
+++ b/src/telemetry/backend/service/TelemetryBackendService.py
@@ -88,7 +88,6 @@ class TelemetryBackendService(GenericGrpcService):
"""
Method receives collector request and initiates collecter backend.
"""
- # print("Initiating backend for collector: ", collector_id)
LOGGER.info("Initiating backend for collector: {:s}".format(str(collector_id)))
start_time = time.time()
self.emulatorCollector = NetworkMetricsEmulator(
@@ -103,13 +102,13 @@ class TelemetryBackendService(GenericGrpcService):
if not self.metric_queue.empty():
metric_value = self.metric_queue.get()
LOGGER.debug("Metric: {:} - Value : {:}".format(collector['kpi_id'], metric_value))
- self.GenerateCollectorResponse(collector_id, collector['kpi_id'] , metric_value)
+ self.GenerateKpiValue(collector_id, collector['kpi_id'] , metric_value)
time.sleep(1)
self.TerminateCollectorBackend(collector_id)
- def GenerateCollectorResponse(self, collector_id: str, kpi_id: str, measured_kpi_value: Any):
+ def GenerateKpiValue(self, collector_id: str, kpi_id: str, measured_kpi_value: Any):
"""
- Method to write kpi value on TELEMETRY_RESPONSE Kafka topic
+ Method to write kpi value on VALUE Kafka topic
"""
producer = self.kafka_producer
kpi_value : Dict = {
@@ -118,7 +117,7 @@ class TelemetryBackendService(GenericGrpcService):
"kpi_value" : measured_kpi_value
}
producer.produce(
- KafkaTopic.VALUE.value, # TODO: to the topic ...
+ KafkaTopic.VALUE.value,
key = collector_id,
value = json.dumps(kpi_value),
callback = self.delivery_callback
@@ -146,7 +145,7 @@ class TelemetryBackendService(GenericGrpcService):
"kpi_value" : measured_kpi_value,
}
producer.produce(
- KafkaTopic.TELEMETRY_RESPONSE.value, # TODO: to the topic ...
+ KafkaTopic.TELEMETRY_RESPONSE.value,
key = collector_id,
value = json.dumps(kpi_value),
callback = self.delivery_callback
--
GitLab