問題タブ [complex-event-processing]

私はエスパーの初心者で、助けてもらいたいです。私はすでに CSV ファイルで Esper を使用することができましたが、ソケットを介して送信されるイベントとして Java オブジェクトを使用する必要があり、インターネット上でガイドとして使用できる簡単な例を見つけることができません。

それらに基づく簡単な例はありますか？

とにかく、私が作ろうとしているコードをここに置いておきます。実行しても何も起こりません。ソケット接続が機能していないようです。

サーバー クラス (イベント クラスも含まれます)。イベントを送信することになっています：

そしてエスパー系クラス。

誰かが私を助けようとするのに時間がかかる場合は、事前にどうもありがとう.

名前付きウィンドウがあるとしましょう：

ここTestEventで、RevisionEvent、およびTestEventBaseは、それぞれTestEventDeltaのベースイベントとデルタイベントで定義されTestEventます。ここでの鍵はですFieldA。

現在、ウィンドウにベースイベントのないデルタイベントがある場合、Esperはこのデルタイベントをサイレントに破棄しているように見えます。したがって、たとえば、デルタイベントがベースイベントの前に来る場合、デルタは破棄されるため、ウィンドウ内の行の状態はベースイベントのみのようになります。

私の質問は、たとえば、これが発生したときに特別な処理を行うために、ウィンドウに入ることができない場合にデルタイベントをキャッチする方法はありますか？

アプリケーションでメッセージを失わないようにする必要があり、Esperが他のメッセージではなく一部のメッセージを黙って破棄している場合、イベントがウィンドウに入ったことを100％確実にするにはどうすればよいですか？

よろしくお願いします！

StreamInsight 2.1 を使用していますが、予期しないパフォーマンスの問題が発生しています。

私は、1 秒あたり 5,000 から 10,000 のイベントで入ってくる財務データの入力アダプターを 1 つ持っています。次に、その入力に対して多数のクエリを実行します。各クエリはまったく同じパススルー クエリに接続されるため、まったく同じ入力データを使用するクエリが 1000 あります。

システムがこれを処理できるかどうかをテストするために、イベントをリリースするだけの出力アダプターにイベントをパススルー ( d in fullStream select d から) するだけの 1000 個のクエリを作成しました。

この方法で 1,000 件のクエリを実行すると、システムがストリームについていけなくなります。それはますます後ろに落ちます。これを 100 クエリにトリミングすると、システムは完全に維持されます。

StreamInsight でパフォーマンスの壁にぶつかっただけですか? 私が構築しているタイプのソリューションを処理できませんか? それとも、私はここで何かばかげたことをしていますか....何か助けがあれば、それを速くするために他に何ができるかわからないでしょう。1000 を超えるクエリを実行できるようにする必要があり、これよりもはるかに複雑なクエリを実行する必要があります。

Drools 5.4.0.Final でスライディング タイム ウィンドウを使用しようとしましたが、次の公式ドキュメントのスニペットが与えられました。

と

私は、混合形式が有効であると考えていました:

しかし、私が間違っていない限り、期待どおりに動作しません (つまり、過去 2 分間に発生した RHT Stock Ticks のみを考慮してください)。そして、結果の論理がわかりませんでした。

誰かが私にそのトリックを説明してくれませんか?

ありがとう。

CEPのアプリケーションニーズに合わせてESPERを実装しました。EPLを使用しているときに、次のような特定のシナリオに遭遇しました。

2つのイベントを左外部結合と組み合わせて、最初の各イベントがステートメントをトリガーでき、特定のプロパティを含む2番目のストリームのイベントのみが発生するようにしました。いくつかのフィールドに基づいて一意のデータを格納するためのビューを作成しました。私のEPLは

構成ファイルのCombinedEventdataTypeにjava.util.Mapタイプを使用しています

次に、テストシナリオを検討します

1. IDが異なるが同じ名前のタイプT1の2つのイベントがシステムに入力されました
   
2. タイプT2の1つのイベントがシステムに入力されます

ビュー仕様により、タイプT1の両方のイベントがビューに存在し、タイプT2のイベントがシステムに入ると、タイプEvent BeanのNewDataパラメーターにはT1の両方のイベントが含まれます（コードでイベントリスナーを使用していた場合）が、最初のEPLステートメントとして'StmtGroupingEvent'に対してタイプT2のイベントを予期していたが、代わりにイベントBeanを検出したため、2番目のステートメントに挿入するように指定します。タイプが一致しないエラーを検出します。

そのため、EPLで配列型のデータを処理する必要があります。これは面倒です。

一方、シナリオが次の場合：

1. タイプT1の1つのイベントのみがシステムに入力されます。
   
2. タイプT2の1つのイベントがシステムに入力されます。

このシナリオでは、イベントBeanがタイプT2にタイプキャストされたため、エラーは発生しません。

だから私にこれを行う別の方法を提案してください。

ありがとう

私は tibco を使用しますが、その技術的なスタックについて混乱しています。

BPM エンジン - TIBCO iProcess | CEP エンジン - TIBCO ビジネス イベント | TIBCO ActiveSpaces

これは正しいです？BusinessWorks の出番はどこでしょうか?

WSO2 SOAトポロジー全体を理解しようとしていますが、CEPとBAMがどのように組み合わされているかを理解できません。

1. CEPは、処理されたイベントの視覚的な監視を提供できますか（WSO2 GSとの統合など）
2. WSO2のWebサイトには、後処理のためにCEPがBAMと緊密に統合されていると書かれていますが、同じことやその方法を説明するシナリオは見つかりませんでした。
3. なぜCEP+BAMを一緒にするのですか？あらゆるユースケース

カサンドラの集約のためのレインバードプロジェクトがメインプロジェクトでコミットされているかどうか誰か知っていますか?

リアルタイム分析の選択について誰かアドバイスはありますか? CEPタイプの機能についてもS4を考えていました。

よろしく。トム

「B」イベント (STREAM モード) の間に「A」イベントをカウントするための最良の方法 (実際にはよだれ融合の方法) を見つけることができません。シーケンスの例は次のとおりです。

ユースケースは

シーケンスの有効性を検証します。つまり、各「B」イベントの間に常に 3 つの「A」イベントがあります。

そのような状況で「ウィンドウオーバー」の概念が適切かどうかはわかりません。助けてくれてありがとう、私はまだ CEP のやり方で考えるのに苦労しています。