X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcollector%2Fcollectors%2Fopenstack.py;h=30bab0cc435b03f735224f9d62b302e9792f1c19;hb=e71feff83ee0acd22eb2cfc8b57f9b0ad25e4651;hp=5053902152891939c8102881aa1fb2815acf8d9f;hpb=51f4486b06781541ee15ea332261247ed3e930f6;p=osm%2FMON.git diff --git a/osm_mon/collector/collectors/openstack.py b/osm_mon/collector/collectors/openstack.py index 5053902..30bab0c 100644 --- a/osm_mon/collector/collectors/openstack.py +++ b/osm_mon/collector/collectors/openstack.py @@ -31,9 +31,8 @@ from keystoneauth1.identity import v3 from osm_mon.collector.collectors.base_vim import BaseVimCollector from osm_mon.collector.metric import Metric -from osm_mon.core.common_db import CommonDbClient from osm_mon.core.auth import AuthManager -from osm_mon.core.exceptions import MetricNotFound +from osm_mon.core.common_db import CommonDbClient from osm_mon.core.settings import Config log = logging.getLogger(__name__) @@ -100,7 +99,8 @@ class OpenstackCollector(BaseVimCollector): for param in vdu['monitoring-param']: metric_name = param['nfvi-metric'] gnocchi_metric_name = METRIC_MAPPINGS[metric_name] - start_date = datetime.datetime.now() - datetime.timedelta(seconds=self.granularity) + delta = 10 * self.granularity + start_date = datetime.datetime.now() - datetime.timedelta(seconds=delta) resource_id = self._get_resource_uuid(nsr_id, vnf_member_index, vdur['name']) try: measures = self.gnocchi_client.metric.get_measures(gnocchi_metric_name, @@ -114,19 +114,3 @@ class OpenstackCollector(BaseVimCollector): log.debug("No metric found: %s", e) pass return metrics - - def collect_one(self, nsr_id: str, vnf_member_index: int, vdur_name: str, metric_name: str) -> Metric: - gnocchi_metric_name = METRIC_MAPPINGS[metric_name] - start_date = datetime.datetime.now() - datetime.timedelta(seconds=self.granularity) - resource_id = self._get_resource_uuid(nsr_id, vnf_member_index, vdur_name) - try: - metrics = self.gnocchi_client.metric.get_measures(gnocchi_metric_name, - start=start_date, - resource_id=resource_id, - granularity=self.granularity) - if len(metrics): - metric = Metric(nsr_id, vnf_member_index, vdur_name, metric_name, metrics[-1][2]) - return metric - except gnocchiclient.exceptions.NotFound as e: - log.debug("No metric found: %s", e) - raise MetricNotFound()