問題タブ [esper]

イベントストリーム処理について、coral8 と esper を比較した分析を行った人はいますか?

私は複雑なイベント処理に非常に興味があり、Esper を検討しています。しかし、私の会社は反 GPL のスタンスをとっており、Apache や BSD のようなよりビジネスに適したライセンスの下で、GPL 以外の代替手段があるかどうか疑問に思っていました。

CEP ベースのアプリケーションを構築する方法について詳しく知りたいです。そこで、いろいろ調べてみると、いくつかの製品が見つかりました (概要はhttp://rulecore.com/CEPblog/?page_id=47にあります)。

しかし、現時点ではかなりの数があるため、どれが最適かはわかりません。全体として、無料で利用できるものを検討します。残りは、個人的な使用には少し高価です;）

Esper は無料ですが、Esper studio がなければ、cep アプリを開発するのはかなり面倒に思えます。Streambase は無料の試用版を提供していますが、これをどれくらいの期間使用できるかはわかりませんでした (1 か月だけであれば、それ以上の調査には役立ちません)。Oracle CEP スイートは非常に完成度が高いように見えますが、cep シーンでは、私が見る限りでは、Esper や Streambase に比べて認知度が最も低くなっています。

では、cep 開発を開始する最良の方法について何かヒントはありますか? オラクルのドキュメントの作業に時間を費やす価値はありますか?それとも、Esper または Streambase から始める方がよいでしょうか?

乾杯、

アンドレアス

ファイルから読み取ったストリームをフィードする非リアルタイムのEsper構成があります。ストリーム全体の統計を計算し、最後に1つの値を出力する式を作成しようとしています。たとえば、Esperには、ビューにX秒ごとに出力を強制するセマンティクスがありますが、フィードするイベントがこれ以上ないことがわかっている場合に、ビューまたはエンジンに出力を「フラッシュ」するように要求するセマンティクスがあります。

漠然とした質問部門では、入力アダプターとしてJMSを使用してEsperを使用した人はいますか？もしそうなら、そこにサンプルコードはありますか？

質問環境はJavaEE、Springに関連しています

着信メッセージの任意のTCP（または他の）リスナーを開始および停止できるシステムを開発しています。これらのメッセージを認証する必要があるかもしれません。これらのメッセージは、解析して他のエンティティに保存する必要があります。これらのエンティティは、格納するフィールドをモデル化します。

したがって、たとえば、2つのテキストフィールドFillLevel1とFillLevel2を持つことができるproperty1がある場合、テキストでF1 = 100; F2=90として指定された両方の塗りつぶしレベルを持つメッセージをTCPで受信できます。

後で、メッセージF1 = xx; F2 = xx; F3 = xxの受信を開始したときに、FillLevel3などの別のファイルを追加できます。しかし、これはシステムモデラー側の意識的な決定です。

私の質問は、メッセージの解析と保存に何を使用するのが良いと思いますか。ETL（他のシステムで使用されているPantahoを使用）では、生のメッセージを保存し、タスクエグゼキューターを使用してそれらを1つずつ消費し、ルールに従って変換されたメッセージを保存します。

EsprまたはDroolsを使用して同じことを行い、ルールを保存してタイマーで実行することもできますが、ルールを作成することでどれほど動的にできるかはわかりません（実行中のシステムで、できればほとんどの場合、エンドユーザーが作成する必要があります）ユーザーフレンドリーな方法、つまりスクリプトやコードなし、GUIのみ）

エンドユーザーは、解析ルールを変更できる必要があります。エンドユーザーがアーカイブデータも変更したい場合もあります（たとえば、上記の例では、FillLevelの新しい値が追加された場合、前の値にFillLevel=-99を入れてデータを作成します。一貫性のある）。

説明をお願いします。少し修正が必要な気がします。

ありがとう

複雑なイベント処理 (Esper) テクノロジを使用して、システムでリアルタイムのローソク足計算を提供しています。値の計算はうまく行っていますが、ろうそくウィンドウが完全な分 (1 分のろうそく) で開始し、次の分が始まる前に終了することを確認するのは難しいと思います (つまり、ろうそく 1[06:00.000 - 06:00.999]、ろうそく2[06:01.000 - 06:01.999] など...)。

そのような機能を提供できるエスパーのクエリ言語のパターンまたはコマンドはありますか?

建設的なコメントと指示をいただければ幸いです。

私は、Java で Esper イベント ストリーム エンジンを使用する初心者です。シナリオは、イベントが POJO として入ってくるというものです。彼らは私がフィルタリングしたいフィールドを持っています。フィルタリングされた値は、時間の経過とともに変化します。変更が発生するたびに新しいステートメントを削除して挿入するのは避けたいと思います。

例：

イベントの名前は「MyEvent」で、フィールドは「source」です。値は、' home '、' work '、または ' school ' のいずれかです。Web サービスにより、ユーザーは関心のある「source」の値を変更できます。EPL ステートメントは次のようになります。

したがって、「学校」はいつでも削除でき、その影響はできるだけ早く反映されなければなりません。問題は、これをどのように実現するのが最善かということです。更新が有効になるまでの待ち時間のため、キャッシュされたデータベース呼び出しを除外しました。

アイデアは次のとおりです。

1) List 型の「sources」フィールドを持つ「SourcesOfInterest」という名前のストリームを作成し、ステートメントを次のように変更します。

Web サービスは、'SourcesOfInterest' イベントをこのストリームに挿入し、最新のイベントのみが表示されます。構文が正しいかどうかさえわかりません。

2) ステートメントがランタイム変数を参照するようにします。次に、ステートメントは次のようになります。

Web サービスが呼び出す

他のオプションはありますか？これらのいずれかに対するパフォーマンスの問題はありますか?

ユーザー定義関数を Esper API に登録しようとしています。クラスまたは文字列型の引数を取ります

http://esper.codehaus.org/esper-4.0.0/doc/api/com/espertech/esper/client/ConfigurationOperations.html#addImport(java.lang.String )

エラーメッセージ

Javaクラスをインポートできます

@larsmans:クラスは Java クラス クラスにのみ存在するようです