kemko/keenetic-grafana-monitoring
1
0
Fork 0
mirror of https://github.com/kemko/keenetic-grafana-monitoring.git synced 2026-01-01 15:45:43 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

Refactor code

Browse Source
This commit is contained in:
Vitaliy Skypnyk
2021-11-10 21:56:26 +00:00
committed by Vitaliy Skrypnyk
parent 9435104f14
commit 4ef76e8792
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
influxdb_writter.py
View File

@@ -15,4 +15,4 @@ class InfuxWriter(object):
logging.info("Connecting to InfluxDB: " + self._configuration['url']) logging.info("Connecting to InfluxDB: " + self._configuration['url'])
def write_metrics(self, metrics): def write_metrics(self, metrics):
self._write_api.write(bucket=self._configuration['bucket'], record=metrics) self._write_api.write(bucket=self._configuration['bucket'], org=self._configuration['org'], record=metrics)

5
keentic_influxdb_exporter.py
View File

@@ -4,7 +4,6 @@ import logging
import os import os
import time import time
from typing import Dict, List from typing import Dict, List
from influxdb_client.client.write.point import Point
from jsonpath_rw import parse from jsonpath_rw import parse
@@ -81,12 +80,12 @@ class KeeneticCollector(object):
@staticmethod @staticmethod
def create_metric(measurement, tags, values): def create_metric(measurement, tags, values):
return Point.from_dict({ return {
"measurement": measurement, "measurement": measurement,
"tags": tags, "tags": tags,
"time": time.time_ns(), "time": time.time_ns(),
"fields": values "fields": values
}) }
@staticmethod @staticmethod
def get_first_value(array): def get_first_value(array):