import logging
import time
import socket
-import peewee
import asyncio
from osm_mon.dashboarder.service import DashboarderService
log.debug("Received message from kafka for deleting user")
user = values['username']
self.service.delete_grafana_user(user)
- log.info("Grafana user deleted: %s", user)
elif topic == "users" and key == "edited":
log.debug("Received message from kafka for associating user to team")
user_id = values["_id"]
try:
self.create_dashboards()
time.sleep(int(self.conf.get('dashboarder', 'interval')))
- except peewee.PeeweeException:
- log.exception("Database error consuming message: ")
- raise
except Exception:
log.exception("Error creating dashboards")