Skip to content

Make percentage string values as floats/ints in InfluxDB #7879

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
pvizeli merged 4 commits into from
Jun 13, 2017
Merged

Make percentage string values as floats/ints in InfluxDB #7879

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
8ae73b2
Make percentage string values as floats in InfluxDB
philhawthorne Jun 3, 2017
7e18ada
Add tests and remove all trailing non digits
philhawthorne Jun 5, 2017
56e6ca1
Update variable name for InfluxDB digit checks
philhawthorne Jun 5, 2017
b73274b
Fix linting errors for InfluxDB component
philhawthorne Jun 9, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions homeassistant/components/influxdb.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,8 @@
"""
import logging

import re

import voluptuous as vol

from homeassistant.const import (
Expand Down Expand Up @@ -147,6 +149,8 @@ def influx_event_listener(event):
}
]

non_digit_tail = re.compile(r'[\d.]+')
non_decimal = re.compile(r'[^\d.]+')
for key, value in state.attributes.items():
if key != 'unit_of_measurement':
# If the key is already in fields
Expand All @@ -161,6 +165,9 @@ def influx_event_listener(event):
except (ValueError, TypeError):
new_key = "{}_str".format(key)
json_body[0]['fields'][new_key] = str(value)
if non_digit_tail.match(json_body[0]['fields'][new_key]):
json_body[0]['fields'][key] = float(
non_decimal.sub('', value))

json_body[0]['tags'].update(tags)

Expand Down
19 changes: 16 additions & 3 deletions tests/components/test_influxdb.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,10 @@ def test_event_listener(self, mock_client):
attrs = {
'unit_of_measurement': 'foobars',
'longitude': '1.1',
'latitude': '2.2'
'latitude': '2.2',
'battery_level': '99%',
'temperature': '20c',
'last_seen': 'Last seen 23 minutes ago'
}
state = mock.MagicMock(
state=in_, domain='fake', object_id='entity', attributes=attrs)
Expand All @@ -136,7 +139,12 @@ def test_event_listener(self, mock_client):
'fields': {
'state': out,
'longitude': 1.1,
'latitude': 2.2
'latitude': 2.2,
'battery_level_str': '99%',
'battery_level': 99.0,
'temperature_str': '20c',
'temperature': 20.0,
'last_seen_str': 'Last seen 23 minutes ago'
},
}]

Expand All @@ -151,7 +159,12 @@ def test_event_listener(self, mock_client):
'fields': {
'value': out,
'longitude': 1.1,
'latitude': 2.2
'latitude': 2.2,
'battery_level_str': '99%',
'battery_level': 99.0,
'temperature_str': '20c',
'temperature': 20.0,
'last_seen_str': 'Last seen 23 minutes ago'
},
}]
self.handler_method(event)
Expand Down