2019-04-19 09:29:27 -07:00
|
|
|
from sys import exit
|
2018-12-17 17:12:37 -08:00
|
|
|
from logging import getLogger
|
2018-12-04 08:45:18 -08:00
|
|
|
from influxdb import InfluxDBClient
|
2019-01-16 10:03:12 -08:00
|
|
|
from requests.exceptions import ConnectionError
|
2019-01-13 18:19:54 -08:00
|
|
|
from influxdb.exceptions import InfluxDBServerError
|
2018-12-04 08:45:18 -08:00
|
|
|
|
|
|
|
|
|
|
|
class DBManager(object):
|
|
|
|
def __init__(self, server):
|
|
|
|
self.server = server
|
2019-01-11 21:27:06 -08:00
|
|
|
self.influx = InfluxDBClient(host=self.server.url, port=self.server.port, username=self.server.username,
|
|
|
|
password=self.server.password, ssl=self.server.ssl, database='varken',
|
|
|
|
verify_ssl=self.server.verify_ssl)
|
2018-12-17 17:12:37 -08:00
|
|
|
self.logger = getLogger()
|
2019-04-19 09:29:27 -07:00
|
|
|
try:
|
|
|
|
version = self.influx.request('ping', expected_response_code=204).headers['X-Influxdb-Version']
|
|
|
|
self.logger.info('Influxdb version: %s', version)
|
|
|
|
except ConnectionError:
|
|
|
|
self.logger.critical("Error testing connection to InfluxDB. Please check your url/hostname")
|
|
|
|
exit()
|
|
|
|
|
|
|
|
databases = [db['name'] for db in self.influx.get_list_database()]
|
2018-12-04 08:45:18 -08:00
|
|
|
|
|
|
|
if 'varken' not in databases:
|
2018-12-17 17:12:37 -08:00
|
|
|
self.logger.info("Creating varken database")
|
2018-12-04 08:45:18 -08:00
|
|
|
self.influx.create_database('varken')
|
2018-12-17 17:12:37 -08:00
|
|
|
|
|
|
|
self.logger.info("Creating varken retention policy (30d/1h)")
|
2018-12-04 08:45:18 -08:00
|
|
|
self.influx.create_retention_policy('varken 30d/1h', '30d', '1', 'varken', False, '1h')
|
|
|
|
|
|
|
|
def write_points(self, data):
|
2018-12-04 19:17:33 -08:00
|
|
|
d = data
|
2018-12-17 17:12:37 -08:00
|
|
|
self.logger.debug('Writing Data to InfluxDB %s', d)
|
2019-01-13 18:19:54 -08:00
|
|
|
try:
|
|
|
|
self.influx.write_points(d)
|
2019-01-16 10:03:12 -08:00
|
|
|
except (InfluxDBServerError, ConnectionError) as e:
|
|
|
|
self.logger.error('Error writing data to influxdb. Dropping this set of data. '
|
|
|
|
'Check your database! Error: %s', e)
|