Skip to content
Snippets Groups Projects
Commit 80078b21 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Telemetry - Backend:

- Fixed few code issues
parent cf71aede
No related branches found
No related tags found
2 merge requests!294Release TeraFlowSDN 4.0,!282Resolve "(CTTC) Auto-start telemetry collection when a device endpoint is activated"
......@@ -106,7 +106,7 @@ class TelemetryBackendService(GenericGrpcService):
Method receives collector request and initiates collecter backend.
"""
# print("Initiating backend for collector: ", collector_id)
LOGGER.info("Initiating backend for collector: ", collector_id)
LOGGER.info("Initiating backend for collector: {:s}".format(str(collector_id)))
start_time = time.time()
while not stop_event.is_set():
if int(collector['duration']) != -1 and time.time() - start_time >= collector['duration']: # condition to terminate backend
......@@ -165,9 +165,9 @@ class TelemetryBackendService(GenericGrpcService):
Args: err (KafkaError): Kafka error object.
msg (Message): Kafka message object.
"""
if err:
LOGGER.debug('Message delivery failed: {:}'.format(err))
if err:
LOGGER.error('Message delivery failed: {:}'.format(err))
# print(f'Message delivery failed: {err}')
else:
LOGGER.info('Message delivered to topic {:}'.format(msg.topic()))
# print(f'Message delivered to topic {msg.topic()}')
#else:
# LOGGER.debug('Message delivered to topic {:}'.format(msg.topic()))
# # print(f'Message delivered to topic {msg.topic()}')
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment