Monitor

TMA-Monitor

This component provides a generic interface that can be accessed by the probes installed in the different layers of the system to send data about the collected measurements and events. To interact with it, user or probes need to generate and send an HTTP POST to TMA_Monitor endpoint. That endpoint is https://IP_MASTER:32025. The main function of this component is to validate all measurements and events provided by probes. If json file sent by user or probe to TMA_Monitor endpoint is in the expected format, this application returns "0", and the data is forwarded to a FaultTolerantQueue microservice. If the data sent is not valid, the application returns "-1" and also the description of errors occurred, and data is discarded.

This component is developed in Python using Flask web microframework.

FaultTolerantQueue Microservice

This microservice is composed by Apache Kafka and Data Loader. Apache Kafka manages three topics that are responsible for messages exchange between TMA Framework components. To send and receive messages through Apache Kafka topics, it is necessary to create a producer, that is responsible to send messages to a specific topic and create a consumer that reads messages from that topic.

TMA_Monitor component is a producer of topic topic-monitor. On the other side, Data Loader is a consumer of that topic, which means that Data Loader receives all validated data provided by TMA_Monitor and is responsible to format and send them to a storage architecture.


Further instructions on how to deploy TMA-Monitor can be found here.