問題タブ [complex-event-processing]

以下は、当社の Esper EPL ステートメントです。

上記の EPL のように配列値を 1 つだけ取得するのではなく、上記のクエリですべての配列要素 (上記の「inputCounts」で配列サイズを指定) を反復処理するにはどうすればよいでしょうか。

これに関するヘルプは大歓迎です!!

サンニット。

CEP でメモリ不足エラーが発生しています。スレッド ダンプは、モニター上で約 32000 のスレッドがスリープ状態にあることを示しています。また、CEP JVM オプションでメモリ不足で HeapDump を生成するように指定されていても、ヒープ ダンプが生成されません。アドバイスをお願いします。(CEP JVM -Xms256m -Xmx1536m)

1) この CEP では Cassandra が無効になっています
。2) CEP のバージョンは 2.1.0 です
。3) CEP は WSO2 ESB (BAM Mediator を使用) によって前面に配置されています。
4) 実際のペイロード データを CEP に送信するのとは別に、ESB は定期的なハートビートも CEP に送信しています (15 ec ごと)。

5) また、15 分ごとに CEP (cpu/memorythreads) を監視している ESB で JMX エージェントを構成しました
。 6) -XX:HeapDumpPath= パラメータが指定されているにもかかわらず、ヒープ ダンプが見つかりません。

• CEP は、この OOM の前に 7 日間連続して実行されました。再起動後、スレッド数が 1 日あたり約 4000 ～ 5000 スレッドの割合で着実に増加していることがわかります。

CEP ログ..

CEP で構成されたクエリの一部

ありがとうラジブ・パチル

必要に応じて Wso2 CEP 製品を拡張し、この公式の wso2 cep リンクに示されているようにカスタム条件を記述してみます。

ただし、「これは、リリースされた最新の WSO2 Complex Event Processor ドキュメント (バージョン 2.1.0) です」と書かれています。ページの上部に、情報が古くなっているか、間違った情報が含まれているようです。

たとえば、次のように書かれています。

カスタム条件を記述するには、「org.wso2.siddhi.core.executor.conditon.AbstractGenericConditionExecutor」を拡張するクラスを作成し、SiddhiExtionsion アノテーションを追加して、そのクラスをコンパイルし、jar ファイルをクラスパス /repertory/components/lib に追加します。 . 次に、/repertory/conf/siddhi にある siddhi.extension ファイルに、実装クラスの完全修飾クラス名を新しい行に追加します。

（「レパートリー」は「リポジトリ」であると想定しています）。公式の WSO2 CEP パッケージには、"/repertory/conf/siddhi" または "siddhi.extension" (wso2cep-2.1.0) のようなファイルやディレクトリはありません。

このドキュメントで見逃したものはありますか?そうでない場合は、WSO2 CEP でのカスタム条件の記述に関する新しいドキュメントをお勧めできますか?

必要に応じて Wso2 CEP 製品を拡張し、この公式の wso2 cep リンクに示されているようにカスタム条件を作成したいと考えています。

「org.wso2.siddhi.core.executor.conditon.AbstractGenericConditionExecutor」を拡張する拡張クラスを作成し、以下に示すようにその抽象メソッドを実装できます。

この拡張メソッドを次のように使用すると:

この状況では、名前フィールドの先頭に「A」がある場合、startswithA メソッドが true を返すようにしたいと考えています。ただし、CEPでこのクエリを実行すると、イベント全体が実行関数にドロップされます。つまり、「名前」フィールドを引数としてstartswithAメソッドに送信したことを示す兆候はありません。

ストリームのどのフィールドが引数として拡張メソッドに送信されるかを理解するにはどうすればよいですか?

また、次のような条件を書きたい

どうすればこれを達成できますか?

私はESPERを初めて使用します。SQLのようなクエリをチェックしていました。これが私のシナリオです。お気に入りのユースケースを処理する必要があります。1 つの推奨エンジンがあり、12 時間ごとにいくつかの URL をユーザーに推奨します。ユーザーが URL をお気に入りとしてマークするかどうかのいずれかで操作すると、イベントは ESPER に送られます。

1. ユーザーが URL をお気に入りとしてマークした場合、CEP はレコメンデーション エンジンに同じ URL を再度送信しないように指示する必要があります。
2. ユーザーが n 回推奨された後に URL をマークしない場合 (ユーザーが興味を示さない場合)、CEP はレコメンデーション エンジンに同じ URL を再度送信しないように指示します。

進め方を教えてください。Favorite Event を POJO として使おうと思っています。

私は CEP 2.1 に慣れていません。私の質問は、CEP が入力ストリームを保持する時間枠に関連しています。

ある入力ストリームに定期的にデータを送信するとしましょう。「HELLOSTREAM」としましょう。CEP が入力をストリームに保存する時間はどれくらいですか?最大時間などは?

365 日間毎日データを送信すると、366 日にすべてのデータが返されますか、それともある時点でデータが切り捨てられますか (過去 100 日間のみ保持されます) ? クエリで設定した時間枠に関係なく?

制限はありますか？

それぞれが次のプロパティを持つ一連のイベントがあります。

さらに、EPL と Esper でモデル化したい一連の階層またはネストされたルールがあります。各ルールは、そのすべての親ルールがすでにアクティブになっている場合にのみ適用する必要があります (それらすべてに対して一致するインスタンスが発生しました)。例えば：

このルール階層の各レベルに対応するすべてのイベント インスタンスを取得します。たとえば、次のイベントを考えてみます。

ルール階層で、階層の各レベルに対応するすべてのイベントの ID とともにこのインスタンスを報告する必要があります。たとえば、次のようなレポートが必要です。

Esper EPL でこれを達成する (すべてのルールに一致するイベントの ID を取得する) にはどうすればよいでしょうか?