d_mcknight/Varken
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

catch server error for influx

Browse source
This commit is contained in:
Nicholas St. Germain 2019-01-13 20:19:54 -06:00
parent af0cb3bff6
commit 7ec28e51fc
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
varken/dbmanager.py
View file

@ -1,5 +1,6 @@
from logging import getLogger from logging import getLogger
from influxdb import InfluxDBClient from influxdb import InfluxDBClient
from influxdb.exceptions import InfluxDBServerError
class DBManager(object): class DBManager(object):
@ -21,4 +22,8 @@ class DBManager(object):
def write_points(self, data): def write_points(self, data):
d = data d = data
self.logger.debug('Writing Data to InfluxDB %s', d) self.logger.debug('Writing Data to InfluxDB %s', d)
self.influx.write_points(d) try:
self.influx.write_points(d)
except InfluxDBServerError as e:
self.logger.error('Error writing data to influxdb. Dropping this set of data. Check your database! Error: '
'%s', e)