from osm_mon.plugins.OpenStack.Gnocchi import metrics
from osm_mon.plugins.vRealiseOps import plugin_receiver
+cfg = Config.instance()
+
logging.basicConfig(stream=sys.stdout,
- format='%(asctime)s %(message)s',
+ format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
datefmt='%m/%d/%Y %I:%M:%S %p',
- level=logging.INFO)
+ level=logging.getLevelName(cfg.OSMMON_LOG_LEVEL))
log = logging.getLogger(__name__)
def get_vdur(self, nsr_id, member_index, vdu_name):
vnfr = self.get_vnfr(nsr_id, member_index)
for vdur in vnfr['vdur']:
- if vdur['vdu-id-ref'] == vdu_name:
+ if vdur['name'] == vdu_name:
return vdur
raise ValueError('vdur not found for nsr-id %s, member_index %s and vdu_name %s', nsr_id, member_index,
vdu_name)
def get_vnfr(self, nsr_id, member_index):
- vnfr = self.common_db.get_one(table="vnfrs",
- filter={"nsr-id-ref": nsr_id, "member-vnf-index-ref": str(member_index)})
+ vnfr = self.common_db.get_one("vnfrs",
+ {"nsr-id-ref": nsr_id, "member-vnf-index-ref": str(member_index)})
return vnfr
def run(self):
elif vim_type == "vmware":
log.info("This metric_request message is for the vROPs plugin.")
- self.vrops_rcvr.consume(message)
+ self.vrops_rcvr.consume(message,vim_uuid)
else:
log.debug("vim_type is misconfigured or unsupported; %s",