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
代わりにパラメーターを使用して、流入がタグとして使用する必要がある列のリストを渡そうとしましたが、測定を調べたところ、流入が_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