問題タブ [esper]

これの解決策をかなり長い間探しています：

お問い合わせフォームがあります。誰かがそれを介してメールを送信するたびに、ContactEvent（receiver、senderIpAddress）がEsperに発行されます。ここで、特定のIPアドレスが10分間に50を超える連絡先イベントを発行したときにEsperに通知してもらいたいと思います。

以下のコードの構文エラーは、コードの簡略化によるものです

次に、次のように入力します。

最終的には、次のようなイベントリスナーがいます。

これは実際に機能します。私のステートメントリスナーは毎回発行されるので、IPアドレスのメッセージ数が変わるので、それは私が難しいと思うことではありません。（「IPXは過去10分間に43件のメッセージを送信しました」、「IP Xは過去10分間に44件のメッセージを送信しました」、...）「IPXは過去10分間に50件を超えるメッセージを送信しました」というイベントを1つだけ取得したい最後の10分」と別の1つは、それが今その境界を下回ったことを私に告げています。

これを機能させる方法はありますか？

NEsper についてよく読んで、サンプル コードを試してみました。いくつか質問があります：

1. これはイベント プロセッサ エンジンですが、どのようにイベントを取得しますか?
2. データはどこに保存されますか?
3. いつそれをポーリングしますか？
4. 誰がそれを投票しますか？
5. 大きなプロジェクトなどのプロジェクトをダウンロードしました。NEsper を使用する場合は、そのプロジェクトを使用する必要がありますか? 別のプロジェクトをビルドする必要がありますか? どのように使用できますか？

Nesper（Esperの.NETバージョン）を試していると、理解できないいくつかの問題が発生しました。次の単純なEPL（チュートリアルをモデルにしたもの）はエラーで失敗します：

私が得るエラーは次のとおりです。

私の最初の疑いは、Observationクラスから派生したSeenEventクラスでIDが正しく公開されていない可能性があることでした。しかし、ObservationクラスでプロパティIDがPublicとして定義されていることを確認しました。

これはEPLの既知の問題ですか？NesperはEsper（Javaのいとこ）とは異なりますか？

親切な人に、CプログラムからEsperに電話できる料理本の方法を教えてもらえますか？理想的には（私はそう思います）EDLの行を使用してEsper関数/メソッドを呼び出し、値を返したいと思います。

編集：私は保持したい12,000行の動作するCコードがあるので、この質問をします。Esperは、私のCコードにとって非常に重要ないくつかの非常に優れたイベント評価を提供します。JNIは、JavaからCコードを呼び出すことを目的としているようです。おそらく、Cの方が高速であるためです。逆に、CからJavaコードを呼び出して、Esperと呼ばれるJavaパッケージの機能を利用したいと思います。

ありがとう！

MSMQ メッセージを受信し、 NEsperを使用して (ほぼ) リアルタイム分析を実行するシステムがあります。一部のメッセージが遅れて、おそらく異なる順序で届く可能性があります。この状況は、フラグを立てて報告する必要があります。これがどのように機能するかを書かないでください（メタコード）：

メッセージが「過去から」到着した状況をより適切に処理するにはどうすればよいですか。メッセージを処理する必要があるため、例外をスローすることはできませんが、メッセージがあったと言うだけでなく、メッセージの詳細をユーザーに知ってもらいたいN 個の誤って受信されたメッセージ。AggregateExceptionのようなことを考えていましたが、それがどのように機能するかわかりません。何か案は？

ESPERエンジンの学習を始めたかったのですが、エステルネイティブの例は少し複雑であることがわかりました。

esperの使用に関する簡単なJavaコードの例を持っている人はいますか？

esper every-distinct subexpressionをどのようにリセットしますか？

一意のIDを持つ航海レポートがいくつかあり、目的地が変更されたときに検出したいと思います。以下は最初の変更を検出しますが、その後の変更は検出されません。

id = 1、destination = A

id = 1、destination = B

わかった

id = 1、destination = C

検出されませんか？

私はストリーム処理のために Esper (および Storm) を見てきました.Esper はまさに私が望むことをしているようです..つまり、ローリング手段、中央値、複雑なクエリなど...しかし、1 つのことが疑問に思っています。

Esper を使用して複数のインスタンスにスケールアウトするにはどうすればよいですか?

私の知る限り、Storm は分散処理を処理しますが、Esper では自分で処理します。

近い将来、私はそれを行う必要はありませんが、私たちが成長するにつれて、データ量も同様にスケールアウトする必要があります. ほとんどの場合、Amazon EC2 にデプロイされます。

Esper アプリケーションにデータを送信する前に、複数のサーバーとシャード データを実行する必要がありますか?

それを処理するより優雅な方法はありますか？

-サジャル

私はエスパーが初めてで、UpdateListener の更新メソッドが複数のスレッドによって同時に実行されるかどうか疑問に思っていました。その場合、このメソッド内の HashMap への書き込みは安全ではないと結論付けます。それは正しいですか、それとも何か不足していますか?

前もって感謝します

NEsperを使おうとしていて、リターンフィールドとして挿入してから時間がかかるステートメントを作成したいです。

例: Blah.win:time(1 分) から timeElapsed として avg((insertTime - now)) を選択します。

これは可能ですか？insertTime をハックすることはできますが、now 関数はありますか?