From: Benjamin Diaz Date: Wed, 31 Oct 2018 21:47:17 +0000 (-0700) Subject: Adds use of N2VC.FormatApplicationName in collector X-Git-Tag: v5.0.0~15 X-Git-Url: https://osm.etsi.org/gitweb/?a=commitdiff_plain;h=refs%2Fchanges%2F24%2F6824%2F4;p=osm%2FMON.git Adds use of N2VC.FormatApplicationName in collector MonCollector was using its own method for generating the juju app name. It is been replaced by the N2VC one that is also used by LCM on deployment. Signed-off-by: Benjamin Diaz Change-Id: Ic2a19825f055cc9b77404f8cf13152e5b6514214 --- diff --git a/osm_mon/collector/collector.py b/osm_mon/collector/collector.py index 60af579..2c77f28 100644 --- a/osm_mon/collector/collector.py +++ b/osm_mon/collector/collector.py @@ -23,9 +23,7 @@ import json import logging import random -import re import uuid -from string import ascii_lowercase from n2vc.vnf import N2VC from prometheus_client.core import GaugeMetricFamily @@ -44,6 +42,7 @@ class MonCollector: self.kafka_server = cfg.BROKER_URI self.common_db_client = CommonDbClient() self.n2vc = N2VC(server=cfg.OSMMON_VCA_HOST, user=cfg.OSMMON_VCA_USER, secret=cfg.OSMMON_VCA_SECRET) + self.producer_timeout = 5 async def collect_metrics(self): """ @@ -65,6 +64,7 @@ class MonCollector: vca_model_name = 'default' for vnfr in vnfrs: nsr_id = vnfr['nsr-id-ref'] + nsr = self.common_db_client.get_nsr(nsr_id) vnfd = self.common_db_client.get_vnfd(vnfr['vnfd-id']) for vdur in vnfr['vdur']: # This avoids errors when vdur records have not been completely filled @@ -78,11 +78,13 @@ class MonCollector: if 'monitoring-param' in vdu: for param in vdu['monitoring-param']: metric_name = param['nfvi-metric'] - payload = await self._generate_read_metric_payload(metric_name, nsr_id, vdu_name, - vnf_member_index) + payload = self._generate_read_metric_payload(metric_name, + nsr_id, + vdu_name, + vnf_member_index) producer.send(topic='metric_request', key='read_metric_data_request', value=json.dumps(payload)) - producer.flush(5) + producer.flush(self.producer_timeout) for message in consumer: if message.key == 'read_metric_data_response': content = json.loads(message.value) @@ -100,7 +102,7 @@ class MonCollector: metric_reading) break if 'vdu-configuration' in vdu and 'metrics' in vdu['vdu-configuration']: - vnf_name_vca = await self._generate_vca_vdu_name(vdu_name) + vnf_name_vca = self.n2vc.FormatApplicationName(nsr['name'], vnf_member_index, vdur['vdu-id-ref']) vnf_metrics = await self.n2vc.GetMetrics(vca_model_name, vnf_name_vca) log.debug('VNF Metrics: %s', vnf_metrics) for vnf_metric_list in vnf_metrics.values(): @@ -115,24 +117,12 @@ class MonCollector: metrics[vnf_metric['key']].add_metric([nsr_id, vnf_member_index, vdu_name], float(vnf_metric['value'])) consumer.close() - producer.close(5) + producer.close(self.producer_timeout) log.debug("metric.values = %s", metrics.values()) return metrics.values() @staticmethod - async def _generate_vca_vdu_name(vdu_name) -> str: - """ - Replaces all digits in vdu name for corresponding ascii characters. This is the format required by N2VC. - :param vdu_name: Vdu name according to the vdur - :return: Name with digits replaced with characters - """ - vnf_name_vca = ''.join( - ascii_lowercase[int(char)] if char.isdigit() else char for char in vdu_name) - vnf_name_vca = re.sub(r'-[a-z]+$', '', vnf_name_vca) - return vnf_name_vca - - @staticmethod - async def _generate_read_metric_payload(metric_name, nsr_id, vdu_name, vnf_member_index) -> dict: + def _generate_read_metric_payload(metric_name, nsr_id, vdu_name, vnf_member_index) -> dict: """ Builds JSON payload for asking for a metric measurement in MON. It follows the model defined in core.models. :param metric_name: OSM metric name (e.g.: cpu_utilization) diff --git a/osm_mon/collector/prometheus_exporter.py b/osm_mon/collector/prometheus_exporter.py index 58aee05..2bb2e27 100644 --- a/osm_mon/collector/prometheus_exporter.py +++ b/osm_mon/collector/prometheus_exporter.py @@ -71,7 +71,6 @@ class MonPrometheusExporter: log.exception("Error collecting metrics") - class CustomCollector(object): def __init__(self): diff --git a/osm_mon/test/collector/test_collector.py b/osm_mon/test/collector/test_collector.py index 84905b7..2a5491f 100644 --- a/osm_mon/test/collector/test_collector.py +++ b/osm_mon/test/collector/test_collector.py @@ -23,8 +23,7 @@ import asyncio import random import unittest - -from mock import mock +from unittest import mock from osm_mon.collector.collector import MonCollector @@ -35,12 +34,6 @@ class MonCollectorTest(unittest.TestCase): self.loop = asyncio.new_event_loop() asyncio.set_event_loop(None) - def test_generate_vca_vdu_name(self): - vdur_name = 'test-juju-metrics01-1-ubuntuvdu1-1' - expected = 'test-juju-metricsab-b-ubuntuvdub' - result = self.loop.run_until_complete(MonCollector._generate_vca_vdu_name(vdur_name)) - self.assertEqual(result, expected) - @mock.patch.object(random, 'randint') def test_generate_read_metric_payload(self, randint): randint.return_value = 1 @@ -57,6 +50,5 @@ class MonCollectorTest(unittest.TestCase): 'collection_period': 1, 'collection_unit': 'DAY', } - result = self.loop.run_until_complete( - MonCollector._generate_read_metric_payload(metric_name, nsr_id, vdu_name, vnf_member_index)) + result = MonCollector._generate_read_metric_payload(metric_name, nsr_id, vdu_name, vnf_member_index) self.assertEqual(result, expected_payload) diff --git a/osm_mon/test/core/test_common_consumer.py b/osm_mon/test/core/test_common_consumer.py index adbcb1d..97231c0 100644 --- a/osm_mon/test/core/test_common_consumer.py +++ b/osm_mon/test/core/test_common_consumer.py @@ -21,8 +21,8 @@ # contact: bdiaz@whitestack.com or glavado@whitestack.com ## import unittest +from unittest import mock -import mock from kafka import KafkaProducer from kafka.errors import KafkaError from osm_common import dbmongo