問題タブ [siddhi]

WSO2-CEP でクエリを動的に記述する方法。PSQL ユーザーにはクエリを動的に記述するオプションがありますが、それを実現するための CEP ツールの代替手段はありますか?

使用例: 1. ストリーム内で関数とデータの両方が利用可能である場合、いくつかのオプションが必要であるか、アダプター ユーザーが動的にルールを作成できるようにする必要があるとします。

例のために。

蒸気 : 1. function1:sum、function2: avg、function3: count、value1: 1、value2: 2、value3: 3 2. function1:sum、function2: min、function3: max、value1: 1、value2: 2、value3 : 3

ルールは次のように動的に作成する必要があります。

1. .... から value1 として sum(value1)、value2 として avg(value2)、value 3 として count(value3) を選択します。
2. .... から value1 として sum(value1)、value2 として min(value2)、value 3 として max(value3) を選択します。

ありがとうガガン

フライトがジオフェンスに入ったことが検出されるたびにシッディにイベントを発生させようとしていますが、それを行うための正しいクエリがわかりません。

次の入力ストリーム定義があります。

フライトの位置更新を取得するたびに、システム内のジオフェンスごとにこのストリームでイベントが生成されます (約 10 個のジオフェンスがあるため、Siddhi は 10 * 位置更新イベントの数を処理できると考えられていました)。

これは私が始めたクエリです:

ただし、これにより、一致するすべての「b」イベントに対してすべての「a」イベントを評価するため、ジオフェンスエントリイベントが重複します (ジオフェンスにない 5 つのイベントの後に 1 つのイベントが続く場合、5 つのジオフェンスエントリを取得します)。イベント）

そこで、これを回避するために重複イベント検出を追加してみました:

geofences:hashEntry は、エントリ イベントの一意のハッシュコードを生成する、私が作成した関数です。

ただし、最初のUniqueウィンドウですべての一意のハッシュを記録しておく必要があり、これによりメモリリークが発生するのではないかと心配しているため、私はこれを行うことに熱心ではありません. ハッシュはその時点にのみ適用されるため、少しやり過ぎのようです。したがって、重複をチェックするために最大数秒間有効な firstUnique ウィンドウのみが必要です。

私が抱えている大きな問題の 1 つは、複数のフライトと複数のジオフェンスが追跡されている 1 つのストリームがあることだと思います。不可能なことを達成する。

私は今アイデアを使い果たしているので、これに関するアドバイスをいただければ幸いです!

前もって感謝します！

私はSiddhi言語が初めてです。イベント ストリームの最初の 10 分以内にのみイベントを取得する必要があります。このタスクを実行する方法はありますか? 定義された入力ストリームは次のとおりです。

プロジェクトで Sidhhi CEP を Java ライブラリとして使用しています。ここで、高可用性システム (Esper HA に類似) でデータを分析する必要があります。Siddhi の高可用性について少し調べました

http://wso2.com/library/articles/2014/05/high-availability-deployment-in-wso2-complex-event-processor-0/

また、上記のリンクを通過しました

Siddhi Javaライブラリを使用して同じタスクを実行することは可能ですか???

カスタム関数に params を渡し、それを取得したい場合は、次のようにする必要があります。

しかし、30 個のパラメーターがある場合、このプロセスをほぼ 30 回繰り返す必要があり、入力パラメーターで何かが変更された場合は、インデックスも変更する必要があります。だから私の質問は、彼らの名前でカスタム機能でパラメータを取得することは可能ですか? たとえば、次のようにします。

Transformerでも同様のことができますが、Functionでは可能ですか？

私は userStream を持っていますusername,ipaddress,timestamp

UserDetailsTableこの詳細を（メモリ内テーブルに）保存したいので、 upsertを実行する必要があります。ユーザー名と ipaddress が同じ場合に行を更新し、それ以外の場合は新しい行として挿入するにはどうすればよいでしょうか。

例えば：

UserDetailsTable の結果は以下のとおりです