Commit c09c401a authored by Waleed Akbar's avatar Waleed Akbar
Browse files

Refactor TelemetryBackendService to comment out emulator collector implementation.

- New implementation will be added soon.
parent 2ee1dcfd
Loading
Loading
Loading
Loading
+16 −17
Original line number Diff line number Diff line
@@ -27,7 +27,6 @@ from common.Settings import get_service_port_grpc
from common.method_wrappers.Decorator        import MetricsPool
from common.tools.kafka.Variables            import KafkaConfig, KafkaTopic
from common.tools.service.GenericGrpcService import GenericGrpcService
from telemetry.backend.service.EmulatedCollector import NetworkMetricsEmulator

LOGGER             = logging.getLogger(__name__)
METRICS_POOL       = MetricsPool('TelemetryBackend', 'backendService')
@@ -87,23 +86,23 @@ class TelemetryBackendService(GenericGrpcService):
        """
        Method receives collector request and initiates collecter backend.
        """
        LOGGER.info("Initiating backend for collector: {:s}".format(str(collector_id)))
        start_time = time.time()
        self.emulatorCollector = NetworkMetricsEmulator(
            duration           = collector['duration'],
            interval           = collector['interval'],
            metric_queue       = self.metric_queue
        )
        self.emulatorCollector.start()
        self.running_threads[collector_id] = self.emulatorCollector
        LOGGER.info("Initiating backend for collector: (Not Implemented... In progress ) {:s}".format(str(collector_id)))
        # start_time = time.time()
        # self.emulatorCollector = NetworkMetricsEmulator(
        #     duration           = collector['duration'],
        #     interval           = collector['interval'],
        #     metric_queue       = self.metric_queue
        # )
        # self.emulatorCollector.start()
        # self.running_threads[collector_id] = self.emulatorCollector

        while self.emulatorCollector.is_alive():
            if not self.metric_queue.empty():
                metric_value = self.metric_queue.get()
                LOGGER.debug("Metric: {:} - Value : {:}".format(collector['kpi_id'], metric_value))
                self.GenerateKpiValue(collector_id, collector['kpi_id'] , metric_value)
            time.sleep(1)
        self.TerminateCollectorBackend(collector_id)
        # while self.emulatorCollector.is_alive():
        #     if not self.metric_queue.empty():
        #         metric_value = self.metric_queue.get()
        #         LOGGER.debug("Metric: {:} - Value : {:}".format(collector['kpi_id'], metric_value))
        #         self.GenerateKpiValue(collector_id, collector['kpi_id'] , metric_value)
        #     time.sleep(1)
        # self.TerminateCollectorBackend(collector_id)

    def GenerateKpiValue(self, collector_id: str, kpi_id: str, measured_kpi_value: Any):
        """