import logging
import time
-import peewee
-
from osm_mon.collector.backends.prometheus import PrometheusBackend
from osm_mon.collector.service import CollectorService
from osm_mon.core.config import Config
log = logging.getLogger(__name__)
-METRIC_BACKENDS = [
- PrometheusBackend
-]
+METRIC_BACKENDS = [PrometheusBackend]
class Collector:
self._init_backends()
def collect_forever(self):
- log.debug('collect_forever')
+ log.debug("collect_forever")
while True:
try:
self.collect_metrics()
- time.sleep(int(self.conf.get('collector', 'interval')))
- except peewee.PeeweeException:
- log.exception("Database error consuming message: ")
- raise
+ time.sleep(int(self.conf.get("collector", "interval")))
except Exception:
log.exception("Error collecting metrics")