Telemetry Backend Service (93985272) · Commits · TFS / controller

src/telemetry/backend/service/TelemetryBackendService.py

+17 −1

Original line number	Diff line number	Diff line
		@@ -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.