問題タブ [complex-event-processing]

Solaris 10 ボックスに wso2 cep エンジンを正常にインストールしました。イベントとして、UDP フィード (パイプで区切られたデータ行) を受信して​​います。UDP フィードを受信して​​処理するように CEP エンジンを構成するにはどうすればよいですか?

ありがとう

私のプロジェクトでは、データベース テーブルに新しく挿入された行を追跡する必要があります。そして、それらの行を処理のために .net アプリケーションに渡します。私は StremInSight を調べましたが、正しく適合しています。それ以外の場合は、ServiceBroker と StremInSight の両方をクラブにするにはどうすればよいでしょうか。つまり、サービス ブローカーを使用して変更を StreamInsight にストリーミングできますか?

ストリームを結合するために esper を使用しました:

シナリオを考えてみましょう:
1. 2 つの取引がシステムに入力されました
2. 価格が到着し

ました このシナリオでは、ストリームをグループ化すると、取引ごとに 2 つの出力が生成されます。また、これにより、最終出力から 2 つのイベントがトリガーされます。イベント数が増加すると、出力イベント数も増加します。 ID - 03 シンボル - GOOG 数量 - 300
の取引がシステムに入力されると、ID ごとに %ageMV も変更されるため、3 つの新しいイベントもトリガーされます。イベントの数が増えると、UI での処理が難しくなります。 だから私の質問は -これを行う標準的な方法はありますか?

ESPER を使用してルール エンジンを実装する必要があり
ます。そのためには、ルールのクエリを準備する必要があります (他に最適化された方法があれば、提案してください)。ルールは実行時に宣言可能であると同時に変更可能でなければなりません。
また、ルールを定義するための UI を作成する必要があります。
これを行うためのより良い最適化された方法を提案してください。
例:

実行時にさらにいくつかのルールを定義できます。

mule + drools フュージョンを使用して Twitter アプリを作成しようとしていますが、特定のルール「Tweet a caso sospechoso」の rhs でヌル ポインター例外が発生します。わかりません。

drools エンジンがツイート イベントを早期に撤回していると思います。rhs でつぶやきイベントを使用する必要がある場合、イベントはもう存在しません。

スタックトレース

そして、それが役立つ場合、Mule は次のように流れます。

両方のコンストラクターが関与

式を他の EPL ファイルに配布する方法は?

試してみましたが、確認する必要がある2つの問題があります。
1. EPL ファイルに 'Expression' のみを含めることはできません ('Unexpected end' エラー)
2. 別の EPL ファイルで定義された式にアクセスすると、'not found' エラーが発生します。
ここに私の試みがあります:
//epl1.epl

//epl2.epl

私はネットビーンズを使用しています。 eplで単一行関数を作成する方法
を取得すると便利ですか?

StreamInsight で、1 つの入力ソースにさまざまな種類のイベントを別々に処理する必要がある状況に遭遇しましたが、最終的には同じソースからの他のイベントと一致します。

入力ソースが乱数 (簡単にするために、1 と 0) を生成する (非常に) 単純なシナリオを以下に作成しました。数値が偶数の場合は、追って通知があるまで保存します (期間は不明)。数が奇数の場合、偶数ストリームの n-1 と一致させてから、偶数ストリームから n-1 を削除します。一致しない場合、奇数はそれ以上計算せずにそのまま処理されます。偶数ストリームから一致する n-1 を削除するまで、すべてが期待どおりに機能しています。一致が行われ、一致が出力アダプターにプッシュされますが、指定されたイベントに対して別の結合を行うために引き続き使用できます。私が数日間の実験と研究から集めたものは、どういうわけか、偶数のストリーム イベント期間 (ClipEventDuration) をクリップする必要があるということです。おそらく、GenerateEvenJoinQuery のフィルターの一部として、しかし、私が試したすべてのことは何の変化も、望ましくない結果も生み出しませんでした。また、evenStream を Interval 形状に変更しようとしましたが、さらに運が悪かったです。どんな助けや提案も大歓迎です。

たとえば、単純化されたリストが与えられた場合: [ 1, 0, 1, 1, 0, 0, 1, 1, 1 ]

出力は [ 1, 100, 1, 100, 100, 1 ] のようになると思います。

私が取り組んでいる実際のシナリオとしても受け入れますが、最初の出力は実際には不可能です。2 番目と 3 番目の 0 が 1 つの 1 に結合されていることに注意してください。 ]

解決：

もう少し精巧で、潜在的に高速なものを望んでいましたが、処理の遅延がパフォーマンスに役立つ可能性があります。

私はこのようなものが必要です。

w1という名前のwindowから別のイベントに挿入します

しかし、3 番目のイベントは、自動的に派生イベントの再計算をトリガーできませんでした。
4番目のイベントの到着がトリガーされ、必要に応じて出力が得られます。
それを行う標準的な方法はありますか？

新しいイベントがウィンドウに到着するか、ウィンドウを離れるかの合計金額を計算したい。

私は、ユーザーが特定の時間枠で特定のページのセットを特定の順序で閲覧するたびに検出できるJavaベースのWebサーバーモニターアプリケーションを作成しています。この目的のために、私はエスパーライブラリーを使用しています。クエリの最適な定式化について疑問があります。

最初に、Webサーバーに到達するHTTPリクエストのすべての情報を格納するために使用される「Access」オブジェクトを宣言しました。サーバーに新しい要求が発行されるたびに、新しいAccessオブジェクトがインスタンス化され、イベントとしてEPL処理コアに送信されます。

ページA、ページB、次にページCを閲覧するすべてのユーザーを追跡したいとします。このようなケースに対処するための最適なアプローチはどれですか。次の例のように、遷移ごとに1つずつ、複数の結合を実行する必要がありますか？

プロジェクトのイベント処理部分を開発するために次のツールのいずれかを選択する必要がありますが、このツールは ASF 2.0 ライセンスの下にある必要があります。

• SIDDHI >> ASF ライセンスの下で
• ETALIS >> GNU Lesser GPL ライセンスの下で
• JBoss – Drools Fusion >> ASL ライセンス
• ActiveInsight >> Common Public Attribution License 1.0 (CPAL)
• インテリジェント イベント プロセッサ – IEP
• SQLストリーム
• Oracleイベント処理

4つのモミは知っていますが、他のモミはどうすれば確認できますか?