+ measures = self.client.metric.get_measures(openstack_metric_name,
+ aggregation=aggregation,
+ start=time.time() - 1200,
+ resource_id=resource_id)
+ if measures:
+ value = measures[-1][2]
+ except gnocchiclient.exceptions.NotFound as e:
+ # CPU metric in previous Openstack versions do not support rate:mean aggregation method
+ if openstack_metric_name == "cpu":
+ log.debug("No metric %s found for instance %s: %s", openstack_metric_name, resource_id, e)
+ log.debug("Retrying to get metric %s for instance %s without aggregation",
+ openstack_metric_name, resource_id)
+ measures = self.client.metric.get_measures(openstack_metric_name,
+ resource_id=resource_id,
+ limit=1)
+ else:
+ raise e
+ # measures[-1] is the last measure
+ # measures[-2] is the previous measure
+ # measures[x][2] is the value of the metric
+ if measures and len(measures) >= 2:
+ value = measures[-1][2] - measures[-2][2]
+ if value:
+ # measures[-1][0] is the time of the reporting interval
+ # measures[-1][1] is the duration of the reporting interval
+ if aggregation:
+ # If this is an aggregate, we need to divide the total over the reported time period.
+ # Even if the aggregation method is not supported by Openstack, the code will execute it
+ # because aggregation is specified in METRIC_AGGREGATORS
+ value = value / measures[-1][1]
+ if openstack_metric_name in METRIC_MULTIPLIERS:
+ value = value * METRIC_MULTIPLIERS[openstack_metric_name]
+ except gnocchiclient.exceptions.NotFound as e:
+ log.debug("No metric %s found for instance %s: %s", openstack_metric_name, resource_id,
+ e)
+ return value
+
+
+class CeilometerBackend(OpenstackBackend):
+ def __init__(self, vim_account: dict):
+ self.client = self._build_ceilometer_client(vim_account)
+
+ def _build_ceilometer_client(self, vim_account: dict) -> ceilometer_client.Client:
+ sess = OpenstackUtils.get_session(vim_account)
+ return ceilometer_client.Client("2", session=sess)
+
+ def collect_metric(self, metric_type: MetricType, metric_name: str, resource_id: str):
+ if metric_type != MetricType.INSTANCE:
+ raise NotImplementedError('Ceilometer backend only support instance metrics')
+ measures = self.client.samples.list(meter_name=metric_name, limit=1, q=[
+ {'field': 'resource_id', 'op': 'eq', 'value': resource_id}])
+ return measures[0].counter_volume if measures else None