Here's an example that fails in my environment. Using the influx cli:

> create database "test"

In a python shell, with X.X.X.X replaced by the host IP:

>>> import pandas as pd
>>> from influxdb import DataFrameClient
>>> c = DataFrameClient(host="X.X.X.X", database="test")
>>> d = pd.DataFrame(data=[[0],[1]], columns=["A"], index=pd.date_range(start="1-1-2018",end="1-2-2018",freq="1D"))
>>> c.write_points(d, measurement="Test Measurement", field_columns=["A"], protocol="line")
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/home/cruncher/.local/lib/python2.7/site-packages/influxdb/_dataframe_client.py", line 131, in write_points
    protocol=protocol)
  File "/home/cruncher/.local/lib/python2.7/site-packages/influxdb/client.py", line 456, in write_points
    tags=tags, protocol=protocol)
  File "/home/cruncher/.local/lib/python2.7/site-packages/influxdb/client.py", line 506, in _write_points
    protocol=protocol
  File "/home/cruncher/.local/lib/python2.7/site-packages/influxdb/client.py", line 302, in write
    headers=headers
  File "/home/cruncher/.local/lib/python2.7/site-packages/influxdb/client.py", line 263, in request
    raise InfluxDBClientError(response.content, response.status_code)
influxdb.exceptions.InfluxDBClientError: 400: {"error":"unable to parse 'Test Measurement A=0i 1514764800000000000': invalid field format\nunable to parse 'Test Measurement A=1i 1514851200000000000': invalid field format"}
>>> c.write_points(d, measurement="Test_Measurement", field_columns=["A"], protocol="line")
True

And more specifically, the patch we came up with was to change the line at the end of _convert_dataframe_to_lines(...) in _dataframe_client.py from

points = (measurement + tags + ' ' + fields + ' ' + time).tolist()

points = (_escape_tag(measurement) + tags + ' ' + fields + ' ' + time).tolist()

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions