問題タブ [esper]

私が理解しているように、Esper はクエリを使用して構築され、着信イベントに関連するものとそうでないものを区別します。

Esper の使用を検討していますが、自分のシナリオに適しているかどうかわかりません。

私のシナリオ:

多数の顧客についていくつかのことを追跡する必要があります。毎秒大量のイベントが受信され、特定の顧客の進行率を決定する必要があります。

例 1: たとえば、私がマッチを販売しているとします。そのため、非常に速く多くの商品を販売しています。そのため、私は常に多くの取引を行っており、各顧客が購入したマッチの数を追跡したいと考えています. 顧客がマッチを 10 本購入した場合、マッチ用の無料ボックスを入手してもらいたいです。したがって、この単純な例では、エスパーを使用しないでください。

しかし、これが進化する可能性があるため、問題は、顧客が購入した 10 回目のマッチに対して無料のボックスを取得し、その後は 3 回ごとに 1 つの賞金で 2 つのマッチを取得するということになる可能性があります。

マッチを 50 本購入すると、マッチがいっぱい入った XL サイズのマッチ箱が手に入ります。

など、複数のルールが互いに重なり合っています。

エスパーがそれをどのように解決するかについての私の推測：

Esper でこれを行うには、顧客ごとに実行時にクエリを作成する必要があります。しかし、私には 2 000 000 人の顧客がいるため、販売した試合ごとにクエリの量が非常に急速に増加します。（エスパーの仕組みを誤解しているかも？）

今、私は質問だけで立ち往生しています...

クエリの増加によってエスパーのパフォーマンスはどのくらい低下しますか? 顧客固有のクエリを作成せずに、Esper に顧客レベルで計算させることは可能ですか?

また、Esper はスレッド化と安定性に欠けることがあると聞きましたが、これで何か問題があった人はいますか?

私はエスパー全体にまったく慣れていないので、私が探しているものとはまったく違うかもしれません。あるいは、エスパーの使い方を誤解しているだけかもしれません。:)

読んでくれてありがとう！

Java Esper では、タイム ウィンドウのタイマーがいつ終了したかを知りたいです。つまり、たとえば、EPL ステートメント (esper ホームページから引用) では、次のようになります。

このステートメントは、30 秒間の着信イベントの価格の平均を計算するために使用されます。ステートメントがいつ終了するかを確認できるかどうか知りたいです。このステートメントを実行すると、30 秒ごとに 30 秒の要約と 30 秒間の出力を示すステートメントが出力されます。

isStopped() メソッドを使用してみましたが、そうでない限り役に立たないようで、間違って使用している可能性がありますか?

Esper（EPL）ステートメントを使用して、5つのEMA5およびEMA20のウィンドウでの指数移動平均を計算する方法を探しています。

priceEvent（timeStamp、シンボル、および価格）のストリームが着信し、5のスライディングウィンドウ上に単純な移​​動avrageSMAを記述しました。しかし、Esperはかなり新しいので、スライディングウィンドウでの指数移動平均（EMA）を計算する方法を探していました。

http://www.iexplain.org/ema-how-to-calculate/

また、誰かが放物線状のSAR関数を書くのを手伝ってくれるなら、それは大きな助けになるでしょう。

Java プロジェクトのクラスパスに 2 つのスキーマがあります。現在、esper エンジンに送られる xml ファイル (イベントとして) は、理解すべきスキーマを理解していません。この問題はどのように解決できますか? 専門家が提案してください！

7サーバーとしてjbossにデプロイするjavaeeプロジェクトを開発しました。

シナリオは

プロジェクトの参照と展開の設定を確認しました。p1.jarは./libディレクトリにあります。
すべてのクラスは公開されており、アクセス可能です。他に何をチェックする必要がありますか？

注文が成功したかどうかを示す EPL ステートメントを作成しようとしています。

ステートメントは、購入の ID に基づいて、購入と支払いを照合する必要があります。結果には、購入の ID と、購入が支払いと一致したかどうかを示すブール値が含まれている必要があります。

以下のステートメントは、一致が成功したときに true を返します。ただし、購入が支払いに一致せずに 30 秒の時間枠を終了した場合にも false を返したいと思います。

また、イベントが発生する順序が問題にならないのもいいでしょう。たとえば、支払いが購入前に行われた場合。

backEND-Runtime として esper で WSO2 CEP-Server を使用しています。WSO2 は cassandra を使用して siddhi(backEnd-runtime) で永続性を提供しています。ESPER-CEP エンジンで永続性を実装する必要があります。どんな考えでもいただければ幸いです。

私はWSO2-CEPをEsper（ランタイムとして）で使用しています。Esperはマップ上のクエリをタプルのsiddhiとして処理しました。「入力マッピングタイプ」は基本的に、XMLマッピング：XMLからマップまたはタプルなどに必要な入力変換のタイプを宣言します。 xmlイベントをマップに変換してサンプルを実行しますが、「入力イベントとしてマップ」があり、それらをマップのみとして処理したい場合はどうなりますか？どんな助けでもいただければ幸いです!!

csv アダプターでの入力として csv ファイルを使用する esper について助けが必要です。POJO クラスと複数の csv ファイルを使用する必要があります。

上記のリスナーも含む例があれば、私は感謝します。

ありがとう

Esper の 2 つのEventTypeオブジェクトが等しいかどうかを確認しようとしています。等しいとは、それらが同じプロパティを持つ同じイベント タイプであることを意味します。

私はそれを行うための最良の方法は何だろうと思っていました。次のように equals メソッドを使用しても安全ですか。

インターフェイスと同様EventTypeに、すべての実装クラスが equals メソッドをオーバーライドするかどうかはわかりません。このため、上記のコードはお勧めできません。

私が考えることができる他のオプションは、次のようにイベント タイプ ID を比較することです。

ただし、これらの ID がどのように割り当てられているかはわかりません。これは私が探しているものを提供してくれますか、それとももっと良い方法がありますか?