2

我正在使用（使用 DataFrameClient）将值（浮点数）写入 Influx 数据库，以及两个标签：ID 和时间戳

def write_to_influx(ID, value):
    df = pandas.DataFrame(data=[value],index=pandas.date_range(start=datetime.utcnow(), periods=1, freq='S'), columns=['value'])
    client.write_points(df, dataPointID, database="mydb")

在我的循环中，碰巧我连续多次写入同一个数据库，如下所示：

while True:

    value_1,value_2,value_3,value_4,value_5 = some_calculation(x,y,z)

    write_to_influx(value_1, ID_1)
    write_to_influx(value_2, ID_2)
    write_to_influx(value_3, ID_3)
    write_to_influx(value_4, ID_4)
    write_to_influx(value_5, ID_5)

有人告诉我，可以将这些写入请求批处理为一个，这将减少 Influx 的负载。

write_to_influx我实际上在掌握这个问题时从另一个脚本中窃取了该方法。在文档中它说

write_points(points, time_precision=None, database=None, retention_policy=None, tags=None, batch_size=None, protocol=u'json', consistency=None)

参数：points（字典列表，每个字典代表一个点）——要写入数据库的点列表

但是有了write_to_influx(value_1, ID_1)，不仅有一个字典，还传递了一个数据点 ID。

类似于已经应用的方法和文档描述......如果我想将多个值写入多个数据点 ID，我应该传递一个字典列表和一个数据点 ID 列表吗？因为这似乎不起作用：

def write_values_to_influx(ID_list, value_list):

    indexes=pandas.date_range(start=datetime.utcnow().replace(tzinfo=pytz.UTC), periods=1, freq='S')

    dict_list=[]
    for value in value_list:
        df_new= pandas.DataFrame(data=[value],index=indexes)
        dict_list.append(df_new)

    client.write_points(dict_list, ID_list, database="mydb")

而真：

value_1,value_2,value_3,value_4,value_5 = some_calculation(x,y,z)

ID_list=[ID_1,ID_2,ID_3,ID_4,ID_5]
value_list=[value_1,value_2,value_3,value_4,value_5]

write_values_to_influx(ID_list, value_list)

返回错误：

File "/vdp/base_functions.py", line 249, in write_values_to_influx
xyz@crVB    |     client.write_points(dict_list, ID_list, database="mydb")
xyz@crVB    |   File "/usr/lib/python3.6/site-packages/influxdb/_dataframe_client.py", line 123, in write_points
xyz@crVB    |     numeric_precision=numeric_precision)
xyz@crVB    |   File "/usr/lib/python3.6/site-packages/influxdb/_dataframe_client.py", line 282, in _convert_dataframe_to_lines
xyz@crVB    |     dataframe = dataframe.dropna(how='all').copy()

我的问题：如何一次写入多个条目（到同一个数据库）？write_points 是 write 方法吗？DataFrameClient 呢？

4

2 回答 2

2

https://influxdb-python.readthedocs.io/en/latest/api-documentation.html

write_points（点，time_precision=None，数据库=None，retention_policy=None，tags=None，batch_size=None，protocol=u'json'，一致性=None）

参数：
points（字典列表，每个字典代表一个点）——要写入数据库的点列表

您正在使用正确的功能client.write_points，只需发送数据点列表。

于 2019-11-11T15:04:44.680 回答
0

请用

write_api.write(bucket=bucket, record=points)

在python 客户端的 influxdb 2.0 中。

于 2021-05-04T11:26:54.917 回答