From a58acce9b441f2ba48a51fa638258cf70e0efd5a Mon Sep 17 00:00:00 2001 From: Deklan Dieterly Date: Tue, 30 Sep 2014 16:14:53 -0600 Subject: [PATCH] Fix unicode error when logging. Change-Id: I2400bc4e63934f118a4b1b32326585269677c085 --- monasca_persister/persister.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/monasca_persister/persister.py b/monasca_persister/persister.py index 37c1766d..f36e8ce4 100644 --- a/monasca_persister/persister.py +++ b/monasca_persister/persister.py @@ -123,7 +123,7 @@ class AlarmPersister(threading.Thread): self.conf.influxdb.database_name) for message in consumer: - LOG.debug(message.message) + LOG.debug(message.message.value.decode('utf8')) decoded = json.loads(message.message.value) LOG.debug(json.dumps(decoded, sort_keys=True, indent=4)) @@ -202,7 +202,7 @@ class MetricPersister(threading.Thread): self.conf.influxdb.database_name) for message in consumer: - LOG.debug(message.message.value) + LOG.debug(message.message.value.decode('utf8')) decoded = json.loads(message.message.value) LOG.debug(json.dumps(decoded, sort_keys=True, indent=4)) @@ -224,7 +224,7 @@ class MetricPersister(threading.Thread): for dimension_name in decoded['metric']['dimensions']: dimensions[dimension_name] = ( decoded['metric']['dimensions'][dimension_name]) - LOG.debug('dimension %s : %s', dimension_name, + LOG.debug('dimension: %s : %s', dimension_name, dimensions[dimension_name]) time_stamp = decoded['metric']['timestamp']