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

Changes in Telemetry. 

- GenericGrpcService inheritance is added in Telemetry backend class.
- Database folder were missing in working directory in DockerFile of Telemetry Frontend.
parent b7f60ece

src/telemetry/backend/service/TelemetryBackendService.py

+3 −2
Original line number Diff line number Diff line
@@ -24,6 +24,8 @@ from confluent_kafka import Consumer as KafkaConsumer 
from confluent_kafka import KafkaError

from common.tools.kafka.Variables import KafkaConfig, KafkaTopic

from common.method_wrappers.Decorator import MetricsPool

from common.tools.service.GenericGrpcService import GenericGrpcService







LOGGER             = logging.getLogger(__name__)
@@ -31,12 +33,11 @@ METRICS_POOL = MetricsPool('TelemetryBackend', 'backendService') 
# EXPORTER_ENDPOINT  = "http://10.152.183.2:9100/metrics"





class TelemetryBackendService:

class TelemetryBackendService(GenericGrpcService):

    """

    Class listens for request on Kafka topic, fetches requested metrics from device.

    Produces metrics on both RESPONSE and VALUE kafka topics.

    """



    def __init__(self):

        LOGGER.info('Init TelemetryBackendService')

        self.kafka_producer = KafkaProducer({'bootstrap.servers' : KafkaConfig.get_kafka_address()})

src/telemetry/frontend/Dockerfile

+1 −0
Original line number Diff line number Diff line
@@ -64,6 +64,7 @@ RUN python3 -m pip install -r requirements.txt 
WORKDIR /var/teraflow

COPY src/telemetry/__init__.py telemetry/__init__.py

COPY src/telemetry/frontend/. telemetry/frontend/

COPY src/telemetry/database/. telemetry/database/



# Start the service

ENTRYPOINT ["python", "-m", "telemetry.frontend.service"]