From 099e07ea67443fda0c7d99d75653fddb3bc57c7d Mon Sep 17 00:00:00 2001 From: "root@playstation" Date: Tue, 26 Jul 2016 16:15:35 +0200 Subject: [PATCH] Fix keys with . for Elasticsearch 2.0 --- upsc_to_logstash.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/upsc_to_logstash.py b/upsc_to_logstash.py index daf1315..43d1afb 100755 --- a/upsc_to_logstash.py +++ b/upsc_to_logstash.py @@ -9,7 +9,9 @@ import requests import settings -def to_python(status): + +def to_python(raw_status): + status = OrderedDict() integer_fields = [ "driver.parameter.pollinterval", "ups.delay.shutdown", @@ -26,13 +28,14 @@ def to_python(status): "output.voltage", "ups.temperature" ] - for k,v in status.items(): + for k,v in raw_status.items(): if k in integer_fields: v = int(v) elif k in float_fields: v = float(v) - status[k] = v + allowed_key = k.replace('.', '_') + status[allowed_key] = v return status