問題タブ [complex-event-processing]

次のように、EPL クエリでさまざまなユーザーの表示権限を設定したいと考えています。

コンテキストがこれを行うと思いますが、イベントの流れとコンテキストの構成を合理化するための助けが必要です。

したがって、ビューのグループに基づいてコンテキスト パーティションを作成する必要があります。そのような

すべての計算はそれらに基づいて行うことができます。ご覧のとおり、コンテキストの分割キーは単一または二重のプロパティではなく、基本的に同じプロパティのグループです。だから私は次のように書くことはできません

WSOCEPサンプルからサンプルアクセス分析を実行しようとしました。サンプルで指定されたものと同じバケットを作成した後、エラーが発生しましたが、バケットは作成されませんでした。誰かが問題を助けることができますか？

エラーログ：

このエラーは、クエリ式の追加でクエリ構文を指定したときに表示されていました。私がこれを与えていない場合、それはバケツを作成します。

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

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

私のシナリオ:

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

タイプの要素のみを定義できます

複合型要素を持つストリームを定義する方法。例えば

Person上で定義した のストリームを作成する方法。

ESPER のように Pojo クラス定義に関して Stream を定義することは可能ですか?

WSO2 CEP / Siddhiクエリが複数の行を返すことをサポートしているかどうかを知りたいのですが、そうであれば、それらの行のデータを出力XMLにマッピングする方法を教えてください。たとえば、私のイベントストリームには、値を指定できるstatusCodeフィールドがあります。A/ B / CIは、過去5分間のステータスタイプ別のカウントを取得するクエリを作成したいと考えていました。たとえば、A-10、B-5、C-2 ..現在のクエリstatusCodeでgroupbyを使用してステータスのカウントを取得しました

単一のXMLでクエリの結果を取得することは可能ですか？つまり、上記の場合、単一のXMLでA、B、Cをカウントしますか？

ありがとうRajiv

WSO2 Developer Studioを使用してバケットを作成するときにEPLクエリを作成するための構文またはコンテキストのヘルプを提供する方法はありますか？WSO2スタックの外部にEPLクエリエディタが存在しますか？

WSO2 CEPまたはBAMをどのように負荷分散できますか？クラスターモード（アクティブ-アクティブ）にするために必要な構成の変更。

パブリッシャーがThriftを介してこのクラスター化サーバーにイベントを送信する方法、例を提供してください。

主な入力として JMS ブローカーを使用する分散 CEP セットアップがあるとします。

ここで、イベントをトピック X に送信するようにクライアント アプリケーションに指示すると、イベントは CEP クラスター内の各ノードに分散されます。これは、各ノードが同じトピック X をリッスンするためです。各ノードが重複データを受信して​​いるため、特定のデータ フィールドをカウントしています。2 ノード クラスタの場合、カウントは実際の値の 2 倍になります)

Topic の代わりに JMS Queue を使用して CEP を使用できますか? このようにして、イベントデータを最初に取得したノードがキューからメッセージを消費しますか? WSO2 CEP は JMS キューをサポートしていますか?

次の質問があります - 1. WSO2 CEP は JMS キューもリッスンできますか? はいの場合は、記事を共有してください。2. アップストリーム アプリケーションがメッセージをトピックにパブリッシュし、CEP を配布した場合 (2 ノード CEP セットアップ)、両方のノードがこの JMS メッセージを処理し、重複メッセージ データを処理するべきではありませんか?