import json
import logging
import sys
+import os
sys.path.append("/root/MON")
from kafka import KafkaConsumer
from kafka.errors import KafkaError
-from plugins.OpenStack.Aodh import alarming
-from plugins.OpenStack.common import Common
-from plugins.OpenStack.Gnocchi import metrics
+from osm_mon.plugins.OpenStack.Aodh import alarming
+from osm_mon.plugins.OpenStack.common import Common
+from osm_mon.plugins.OpenStack.Gnocchi import metrics
# Initialize servers