DataFrameClient
我正在尝试使用python 驱动程序中的将以下数据帧写入 influxdb 。
change price symbol volume
Time
2019-05-09 10:00:00 1 22 ABCD 450
2019-05-09 10:00:00 2 4 ABCD 2000
2019-05-09 10:00:00 3 1 ABCD 2000
2019-05-09 10:00:00 4 4 ABCD 13000
由于存在重复的时间戳,我正在尝试编辑标签,以便流入不会覆盖现有记录。我尝试了文档中的方法是这样的:
client.write_points(result, tags={'price': pd[['price']]}
database='example', measurement='raw')
但我收到一条错误消息:
Series 的真值是模棱两可的。使用 a.empty、a.bool()、a.item()、a.any() 或 a.all()。
然后,我尝试改用该tag_columns
参数并传入 influx 应用作标签的列列表,但是当我查看测量结果时,我看到 influx 创建了带有_1
包含数据的后缀的新列,而原始列是空的:
time change price price_1 symbol volume volume_1
---- ------ ----- ------- ------ ------ --------
2019-05-09T10:00:00Z 3 1 ABCD 2000
2019-05-09T10:00:00Z 2 4 ABCD 2000
2019-05-09T10:00:00Z 4 4 ABCD 13000
2019-05-09T10:00:00Z 1 22 ABCD 450