問題タブ [influxdb-2]

TL;DR 私は Influxdb v2.0 を使用しており、(GUI のように) Influx クエリ構文を使用しています。デジタル 0/1 状態の複数のシリーズ (同じ _field、異なるタグ) があり、それらを合計したいと考えています。問題は、状態が不規則な時間間隔でデータベースに保存されることです。つまり、各タグの実際の実際の値は、可能な限り最後のポイントでいつでも照会する必要があります。関数として「last」を使用してaggregateWindowを試しましたが、最後に、ポイントが保存されていないウィンドウのテーブルをドロップするだけです。とにかくそれらを要約できるものはありますか？どのような方法でも構いません (データのエクスポートや、lmao の代わりに他の言語のスクリプトを使用するなど)。前もって感謝します。

シナリオ

私のチームは、以前に現実世界のイベントの各人を表す電話番号を使用してチェックイン/チェックアウト システムを実装し、InfluxDB v2.0 をデータベースとして使用することにしました (Grafana を介して簡単に監視できるように選択しました)。 . チェックイン/チェックアウト値のポイントを格納するバケットがあり、すべて同じスキーマです。スキーマは次のとおりです。

誰かがイベントをチェックインするたびに、値 1 のポイントが挿入されます。逆に、誰かがイベントをチェックアウトするたびに、値 0 のポイントが挿入されます。ユーザーが以前にチェックインしたように API を再度トリガーして再度チェックインした場合、ポイントが重複する可能性があることに注意してください (ただし、これは同じ状態の 1 と見なされます)。したがって、データはデジタルの 0/1 状態に似ていますが、ポイントの時間間隔が不規則で、電話番号ごとに 1 つのグラフ ラインがあります。同じ電話番号でも種類が違うと、私たちにとっては別人に見えます。

プロジェクトはすでに展開されており、データの後処理を行う必要があります。問題は、全期間のイベント内人口のグラフを視覚化することです。数学的な観点では、これは各人の状態 (0/1 ライン) を経時的に合計することで簡単に解決できるはずです。Influx クエリで最初に次のようなことを試しました。

結果は非常に有望に見えます.2色の法線とスタッフの人口グラフです. しかし、よく見ると、Influx の sum 関数は、実際には各ウィンドウの各ポイントの _value を合計しています。つまり、ポイントのないウィンドウの場合、合計関数は実際にはデータベース内のすべての人を合計しません。目標は、ポイントのないウィンドウの実際の _value を合計することです (これらのウィンドウの _value は、最後のポイントの _value と同じにする必要があります。たとえば、午後 7 時にチェックインした場合、_value はすべて 1 にする必要があります7.00pm以降の時間でも、ウィンドウによっては意味がありません)。次に、次のようなことを試しました。

各ウィンドウに最後のポイントを使用し、ウィンドウを空の _value で前の可能なポイントで埋めてから、各ウィンドウの _value を再度合計します。しかし、その後、関数が実際に空のテーブルをドロップすることがわかりました。つまりlast、ポイントのないウィンドウがドロップされます (createEmpty は役に立たない)。last問題は、空のテーブルを削除せずに関数を見つける必要があることです。reduceのような独自のロジックを作成しようとしましlastたが、残念ながら思い通りにはなりませんでした (コーディングが間違っていた可能性があります)。

お気づきの点がございましたら、お助けください。どうもありがとうございました。