問題タブ [siddhi]

WSO2 CEP / Siddhiクエリが複数の行を返すことをサポートしているかどうかを知りたいのですが、そうであれば、それらの行のデータを出力XMLにマッピングする方法を教えてください。たとえば、私のイベントストリームには、値を指定できるstatusCodeフィールドがあります。A/ B / CIは、過去5分間のステータスタイプ別のカウントを取得するクエリを作成したいと考えていました。たとえば、A-10、B-5、C-2 ..現在のクエリstatusCodeでgroupbyを使用してステータスのカウントを取得しました

単一のXMLでクエリの結果を取得することは可能ですか？つまり、上記の場合、単一のXMLでA、B、Cをカウントしますか？

ありがとうRajiv

siddhi クエリ言語を使用しようとしていますが、誤用しているようです。

次の streamdef を持つイベントがいくつかあります。

次のようなクエリを使用して、同じプロセス値と同じフラックス値でイベントをフィルタリングしようとしています:

これを試すたびに、出力は生成されません。フィルターを外すと

すべてのイベントが出力に表示されます。

クエリの何が問題になっていますか?

siddhi ( http://siddhi-cep.blogspot.com/ ) / WSO2 には、次のようなクエリで機能する機能がありますか?

1) 成功に続く 5 つのエラー

2) 5 つのエラーに続いて 5 つの致命的なエラーと 1 つの成功

時間ウィンドウが存在すると仮定できます

誰かが例を提供できますか?

シッディで条件付きで選択された 3 つのイベントに参加したいです。これを行うには、バケット定義内に 2 つのクエリを定義します。

最初のクエリ定義は次のとおりです。

2番目のもの：

クエリの実行時に ArrayIndexOutOfBounds 例外が発生し続けます。私は何を間違っていますか？例外ログ:

ちなみに、入力マッピングは正しく、バケットは正常にデプロイされています。

バケット定義:

こんにちは。

私はアーキテクト SW Competence Centers として Company Indra (www.indra.com) に執筆しています。

この分野では、通常、オープンソース ドメインのオープンソースおよび商用の CEP を使用します。これまで、常に Esper CEP を使用してきましたが、GPL に問題があることがわかりました。

Siddhi CEP を試すことに興味があり、そのためにこの CEP を使用したプロジェクトを開始しました。

問題は、すべての CEP を含む機能とプロジェクトの必要性を特定できなかったことです: イベントの不在を検出します。

Esper では、次のようなクエリでこれを行うことができます。

製品ロードマップにこの機能を組み込むかどうか、およびこの問題の回避策があるかどうかを知りたいと考えていました。

感謝と挨拶。

カスタム OutputAttributeProcessor の作成についていくつか質問があります。私は WSO2 CEP 2.1.0 と siddhi 1.1.0 を使用しています。

カスタム OutputAttributeProcessor を作成したいので、2 つの Java クラスを作成します。TestFactory は OutputAttributeProcessorFactory を実装し、Test は OutputAttributeProcessor を実装します。2 つのクラスのパッケージは org.wso2.siddhi.extention です。

TestFactory は createAggregator と getProcessorType をオーバーライドする必要があり、Test は createNewInstance、getType、processInEventAttribute、および processRemoveEventAttribute をオーバーライドする必要があります。

最初の質問は、それぞれの方法についてです。

getProcessorType には何を書くべきですか?

また、processInEventAttribute と processRemoveEventAttribute の違いは何ですか?

さらに、もう一つ質問があります。2 つの Java クラスで構成された jar ファイルを作成します。jar ファイルを /repository/components/lib のクラス パスに追加し、TestFactory の完全修飾クラス名を /repository/conf/siddhi にある siddhi.extension ファイルに追加します。

siddhi.extension の内容は何ですか?

以下は行ですか？

カスタムOutputAttributeProcessorに関するサンプルプログラムがあれば教えてください。

前もって感謝します。

カスタム OutputAttributeProcessor の作成について質問と問題があります。私は WSO2 CEP 2.1.0 と siddhi 1.1.0 を使用しています。

カスタム OutputAttributeProcessor を作成したいので、2 つの Java クラスを作成します。DiscomfortIndexAggregatorFactory は OutputAttributeProcessorFactory を実装し、DiscomfortIndexAggregator は OutputAttributeProcessor を実装します。2 つのクラスのパッケージは org.wso2.siddhi.extention.aggregator.environment です。

2 つの Java プログラムは次のとおりです。

DiscomfortIndexAggregatorFactory.java

DiscomfortIndexAggregator.java

2 つの Java クラスで構成される jar ファイルを作成し、その jar ファイルを /repository/components/lib のクラス パスに追加し、/repository/conf/siddhi にある siddhi.extension ファイルを追加しました。siddhi.extention の内容は以下の通りです。

org.wso2.siddhi.extention.aggregator.environment.DiscomfortIndexAggregatorFactory

上記の設定後に再起動しました。再起動後、エラーログは出力されません。

しかし、バケットの次のクエリを作成しました。

以下のエラーログが出力されます。

方法を教えてください。

前もって感謝します。