X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcollector%2Fbackends%2Fprometheus.py;fp=osm_mon%2Fcollector%2Fbackends%2Fprometheus.py;h=a9bb93803818653c70cbd51b33af035b2f250bc1;hb=8e4179facf22c8096992f0a83caeec9f2f4996c7;hp=fbe6d36b7ebbe29355217f35753958e02d58fe06;hpb=a2eeb474200b8f9ebcaee6fa68fe52b6e1a5e337;p=osm%2FMON.git diff --git a/osm_mon/collector/backends/prometheus.py b/osm_mon/collector/backends/prometheus.py index fbe6d36..a9bb938 100644 --- a/osm_mon/collector/backends/prometheus.py +++ b/osm_mon/collector/backends/prometheus.py @@ -31,44 +31,44 @@ from osm_mon.collector.metric import Metric log = logging.getLogger(__name__) -OSM_METRIC_PREFIX = 'osm_' +OSM_METRIC_PREFIX = "osm_" class PrometheusBackend(BaseBackend): - def __init__(self): self.custom_collector = CustomCollector() self._start_exporter(8000) def handle(self, metrics: List[Metric]): - log.debug('handle') - log.debug('metrics: %s', metrics) + log.debug("handle") + log.debug("metrics: %s", metrics) prometheus_metrics = {} for metric in metrics: if metric.name not in prometheus_metrics: prometheus_metrics[metric.name] = GaugeMetricFamily( OSM_METRIC_PREFIX + metric.name, - 'OSM metric', - labels=list(metric.tags.keys()) + "OSM metric", + labels=list(metric.tags.keys()), ) - prometheus_metrics[metric.name].add_metric(list(metric.tags.values()), metric.value) + prometheus_metrics[metric.name].add_metric( + list(metric.tags.values()), metric.value + ) self.custom_collector.metrics = prometheus_metrics.values() def _start_exporter(self, port): - log.debug('_start_exporter') - log.debug('port: %s', port) + log.debug("_start_exporter") + log.debug("port: %s", port) REGISTRY.register(self.custom_collector) log.info("Starting MON Prometheus exporter at port %s", port) start_http_server(port) class CustomCollector(object): - def __init__(self): self.metrics = [] def describe(self): - log.debug('describe') + log.debug("describe") return [] def collect(self):