From 7ec28e51fc5c6adf964497e29cfa1ca3aaa2d53e Mon Sep 17 00:00:00 2001 From: "Nicholas St. Germain" Date: Sun, 13 Jan 2019 20:19:54 -0600 Subject: [PATCH] catch server error for influx --- varken/dbmanager.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/varken/dbmanager.py b/varken/dbmanager.py index 486d8aa..2a50d4f 100644 --- a/varken/dbmanager.py +++ b/varken/dbmanager.py @@ -1,5 +1,6 @@ from logging import getLogger from influxdb import InfluxDBClient +from influxdb.exceptions import InfluxDBServerError class DBManager(object): @@ -21,4 +22,8 @@ class DBManager(object): def write_points(self, data): d = data 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)