1

DataFrameClientPythonドライバーを使用して、次のデータフレームを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
4

1 に答える 1