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:
parent
31bb8ba21d
commit
906dee94b1
@ -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}
|
||||
|
||||
|
@ -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
|
||||
|
Loading…
x
Reference in New Issue
Block a user