From e415ea71cb820e262ec25bd65ed383af10c04ee0 Mon Sep 17 00:00:00 2001 From: Arseni Lipinski Date: Fri, 12 Apr 2019 15:09:53 +0200 Subject: [PATCH] Change process_message() to static Change-Id: I931a93f9de0df3373e5601a9d7abb29e7f90a8bc --- .../repositories/influxdb/metrics_repository.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/monasca_persister/repositories/influxdb/metrics_repository.py b/monasca_persister/repositories/influxdb/metrics_repository.py index e9641cdc..508c045d 100644 --- a/monasca_persister/repositories/influxdb/metrics_repository.py +++ b/monasca_persister/repositories/influxdb/metrics_repository.py @@ -29,7 +29,8 @@ class MetricInfluxdbRepository(abstract_repository.AbstractInfluxdbRepository): super(MetricInfluxdbRepository, self).__init__() - def process_message(self, message): + @staticmethod + def process_message(message): (dimensions, metric_name, region, tenant_id, time_stamp, value, value_meta) = parse_measurement_message(message) @@ -56,7 +57,7 @@ class MetricInfluxdbRepository(abstract_repository.AbstractInfluxdbRepository): value_meta_field = u'value_meta=' + value_meta_str data = key_values + u' ' + value_field + u',' + \ - value_meta_field + u' ' + str(int(time_stamp)) + value_meta_field + u' ' + str(int(time_stamp)) LOG.debug(data)