問題タブ [influxdb-python]

プロジェクトで influxdb を使用していますが、一度に複数のポイントが書き込まれると、クエリの問題に直面しています。

influxdb-python を使用して、1000 個の一意のポイントを influxdb に書き込みます。

influxdb-python にはinfluxclient.write_points()という関数があります

現在、次の 2 つのオプションがあります。

1. 各ポイントを毎回 1 回 (1000 回) 書き込むか、
2. 1000点をまとめて、すべての点を一度に書きます。

最初のオプション コードは次のようになり (疑似コードのみ)、動作します。

すべてのポイントを書いた後、次のようなクエリを書くと:

1000ポイント全部取れます。

すべての反復ですべての書き込みによって追加されるオーバーヘッドを回避するために、一度に複数のポイントを書き込むことを検討したいと思いました。これはwrite_points機能によってサポートされています。

write_points(ポイント、time_precision=なし、データベース=なし、retention_policy=なし、tags=なし、batch_size=なし)

複数の時系列名に書き込みます。

パラメータ: points (辞書のリスト、各辞書はポイントを表します) – データベースに書き込まれるポイントのリスト

だから、私がしたことは：

この変更により、クエリを実行すると:

結果、1点しか取れません。理由がわかりません。

どんな助けでも大歓迎です。

リストをInfluxDBの値として挿入することは可能ですか? これはjsonです：

代わりに、リストの文字列表現を使用することもできますが、それを以下のようにリストに変換する必要があります。これは正常に機能します。

ast.literal_eval(device_points[0]['ローカル'])

以下は、文字列表現を持つ json オブジェクトです。

リストの書き込みを直接達成する他の方法はありますか?

ありがとう！

psycopg の mogrify 関数のように、InfluxDB Python クライアントで SQL インジェクションの安全な方法でパラメーターを使用する正しい方法はありますか?

• https://github.com/influxdata/influxdb-python/
• http://initd.org/psycopg/docs/cursor.html#cursor.mogrify

以下はかなり危険なようです。

次のようなことが行われたとしたらどうでしょうか。

（これが実際に機能するかどうかはわかりませんが、要点はわかります。）

現在、私は簡単な社内ソリューションを検討しています：

(英語の) 文字、数字、アンダースコア、単純なハイフン、またはピリオド以外のものはすべて削除されます。次の回答に基づく: https://stackoverflow.com/a/5843560/604048

これで私のユースケースはカバーされると思いますが、害を及ぼす可能性のある危険なコーナーケースがあるかどうかはわかりません。レコードについては、これらのクエリを実行しているユーザーには読み取りアクセスしかありません。しかし、私はむしろこの事実に頼りたくありません。将来、誰かがユーザーに昇格した権限を与える可能性があります。

安全だと思いますが、何か他のことをする必要がありますか? これはむしろ、暗号化やハッシュ化のような独自のものを実行しないように人々に言われるケースの 1 つに思えます。

influxdbを使用して、influxdb v4.0.0を使用してローカルinfluxdbにいくつか書き込もうとして'measurements'います...

一部の場所では、dictを使用するか、jsonまたはラインプロトコルを使用できると言われているため、私は少し混乱しています....

ここからhttp://influxdb-python.readthedocs.io/en/latest/examples.html#tutorials-pandasおよびこことここからhttps://github.com/influxdata/influxdb-python/blob/master/influxdb/ client.py

1st -以下を使用して DB オブジェクトを作成します。

2 番目 -データを使用して dict を作成します。

3番目 -データをBDにプッシュ:

プログラムは動作しますが、DB にデータは保存されず、コンソール出力は次のようになります。

なぜ、または何を間違って書いているのか、u'points'エラーの意味がわかりません...誰か助けてくれますか??