Fixes for Influxd 0.9 latest

change 'name' to 'measurement'.
change 'timestamp' to 'time'.
store value_meta as "" instead of "\"\"" when empty.

Change-Id: I391ab269897e6575abd9027b6b4252083a015536
This commit is contained in:
Deklan Dieterly 2015-06-19 14:02:14 -06:00
parent 31bb8ba21d
commit 906dee94b1
2 changed files with 6 additions and 4 deletions

View File

@ -525,12 +525,14 @@ class MetricPersister(AbstractPersister):
ts = time_stamp / 1000.0
data = {"name": metric_name.encode('utf8'),
"timestamp": datetime.fromtimestamp(ts, tz=pytz.utc).strftime(
data = {"measurement": metric_name.encode('utf8'),
"time": datetime.fromtimestamp(ts, tz=pytz.utc).strftime(
'%Y-%m-%dT%H:%M:%S.%fZ'),
"fields": {
"value": value,
"value_meta": json.dumps(value_meta, ensure_ascii=False).encode('utf8')
"value_meta": json.dumps(value_meta,
ensure_ascii=False).encode(
'utf8') if value_meta else ''
},
"tags": tags}

View File

@ -1,6 +1,6 @@
babel
eventlet
influxdb>=1.0.0
influxdb>=2.6.0
iso8601
kafka-python>=0.9.2,<0.9.3
kazoo>=2.0