nebulous/monitoring-data-persistor
Code Issues Proposed changes

Initial Commit

Browse Source 
Initial commit of the component to the repository

Change-Id: Ie61d9c52a4aa66b732c42f9353dd73c34521e912
This commit is contained in:
Andreas Tsagkaropoulos 2024-01-15 13:51:38 +02:00
parent a67c14afc2
commit a777d7691c
4 changed files with 6 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

0
monitoring-data-persistor/.hadolint.yaml Normal file
View File

8
monitoring-data-persistor/src/main/runtime/DataPersistor.py
View File

@ -1,12 +1,9 @@
import logging
import os
import sys
import threading
import time
from jproperties import Properties
from influxdb_client import Point, WritePrecision, InfluxDBClient
from influxdb_client.client.write_api import SYNCHRONOUS
from influxdb_client import Point, WritePrecision
import exn
from Constants import Constants
@ -85,5 +82,4 @@ if __name__ == "__main__":
thread = threading.Thread(target=connector.start,args=())
thread.start()
print("Waiting for messages at the metric list topic, in order to start receiving applications")
print("Waiting for messages at the metric list topic, in order to start receiving applications")

8
monitoring-data-persistor/src/main/runtime/DemoDataPublisher.py
View File

@ -3,13 +3,7 @@ import threading
import time,random
import traceback
from influxdb_client import Point, WritePrecision, InfluxDBClient
from influxdb_client.client.write_api import SYNCHRONOUS
from Constants import Constants
from InfluxDBConnector import InfluxDBConnector
from exn import connector, core
from datetime import datetime
class Bootstrap(connector.connector_handler.ConnectorHandler):
@ -17,7 +11,7 @@ class Bootstrap(connector.connector_handler.ConnectorHandler):
logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
logging.getLogger('main.exn.connector').setLevel(logging.DEBUG)
logging.getLogger('exn.connector').setLevel(logging.DEBUG)
application_name = "_Application1"
metric_list = ["cpu_usage","ram_usage"]

6
monitoring-data-persistor/src/main/runtime/InfluxDBConnector.py
View File

@ -49,11 +49,11 @@ class InfluxDBConnector:
self.write_api.write(bucket=self.bucket_name, org=Constants.organization_name, record=data, write_precision=WritePrecision.S)
def get_data(self):
def get_data(self,metric_name):
query_api = self.client.query_api()
query = """from(bucket: "nebulous")
query = f"""from(bucket: "nebulous")
|> range(start: -1m)
|> filter(fn: (r) => r._measurement == "temperature")"""
|> filter(fn: (r) => r._measurement == "{metric_name}")"""
tables = query_api.query(query, org=Constants.organization_name)
for table in tables: