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

Add influxdb 2.x support

Browse Source
This commit is contained in:
Vitaliy Skypnyk
2021-11-10 21:17:28 +00:00
committed by Vitaliy Skrypnyk
parent b62d650cb5
commit 26ea31e401
10 changed files with 134 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
influxdb_writter.py
View File

@@ -1,27 +1,18 @@
import logging
import requests
from influxdb import InfluxDBClient
from influxdb_client import InfluxDBClient
from influxdb_client.client.write_api import SYNCHRONOUS
class InfuxWriter(object):
def __init__(self, configuration):
def __init__(self, configuration, configuration_file):
requests.packages.urllib3.disable_warnings()
self._configuration = configuration
self._client = InfluxDBClient(self._configuration['host'], self._configuration['port'],
self._configuration['username'], self._configuration['password'],
self._configuration['db'])
self.init_database()
def init_database(self):
logging.info("Connecting to InfluxDB: " + self._configuration['host'])
db_name = self._configuration['db']
# self._client.drop_database(db_name)
if db_name not in self._client.get_list_database():
logging.info("Creating InfluxDB database: " + db_name)
self._client.create_database(db_name)
self._client = InfluxDBClient.from_config_file(configuration_file)
self._write_api = self._client.write_api(write_options=SYNCHRONOUS)
logging.info("Connecting to InfluxDB: " + self._configuration['url'])
def write_metrics(self, metrics):
self._client.write_points(metrics)
self._write_api.write(bucket=self._configuration['bucket'], record=metrics)