X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fevaluator%2Fevaluator.py;h=8f49a66fcb3c2c83a40e2d2b013430f931a5ca32;hb=274a6e9fa4268db2a87525a27bc574c46eaa80dc;hp=7613e0bd8cb8a866942709da1a089e6fa6ee3d09;hpb=058d51d5f8ba1666242a12f52d99bdd74ec7f94f;p=osm%2FMON.git diff --git a/osm_mon/evaluator/evaluator.py b/osm_mon/evaluator/evaluator.py index 7613e0b..8f49a66 100644 --- a/osm_mon/evaluator/evaluator.py +++ b/osm_mon/evaluator/evaluator.py @@ -59,7 +59,7 @@ class Evaluator: OSM_METRIC_PREFIX + metric_name, nsr_id, vdur_name, vnf_member_index) request_url = cfg.OSMMON_PROMETHEUS_URL + "/api/v1/query?" + query_section log.info("Querying Prometheus: %s", request_url) - r = requests.get(request_url) + r = requests.get(request_url, timeout=cfg.OSMMON_REQUEST_TIMEOUT) if r.status_code == 200: json_response = r.json() if json_response['status'] == 'success': @@ -136,8 +136,15 @@ class Evaluator: processes.append(p) p.start() if 'vnf-metric' in vnf_monitoring_param: - log.warning("vnf-metric is not currently supported.") - continue + vnf_metric_name = vnf_monitoring_param['vnf-metric']['vnf-metric-name-ref'] + p = multiprocessing.Process(target=self._evaluate_metric, + args=(nsr_id, + vnf_member_index, + '', + vnf_metric_name, + alarm)) + processes.append(p) + p.start() for process in processes: process.join() @@ -157,7 +164,7 @@ class Evaluator: # Generate and send response resp_message = response.generate_response( 'notify_alarm', - alarm_id=alarm.id, + alarm_id=alarm.uuid, vdu_name=alarm.vdur_name, vnf_member_index=alarm.vnf_member_index, ns_id=alarm.nsr_id,