問題タブ [esper]

Nesper（4.1.2 / 4.5.0）を使用していますが、問題があります。group-by句を使用すると、イベントがサブスクライバーに渡されません。

EPLクエリ：

select Operation, count(*) as OperationCount from OperationEvent.win:time(10 sec) group by Operation

出力は5秒ごとに続きます

サブスクライバー

group by句を削除すると、すべてがうまく機能します。

なにが問題ですか？

Javaアプリケーション内で使用できる無料のイベントソースを探しています。YahooFinanceに似たものを探しています。ここでは、大量の株式情報を照会して、結果をcsvとして取得できます。

理想的には、APIまたはクエリ文字列を含むURLが最適です。

ドキュメントによると、可能なはずのイベントタイプで時間間隔代数メソッドを直接使用しようとしています。create schema最初に、次のような構文を使用していくつかのイベント タイプを定義しようとしました。

このようなクエリを書くと

実際にはエラーなしでコンパイルされます。しかし、結合の代わりにパターンを使用しようとすると、次のようになります

それは私にエラーを与えます:

ドキュメントで説明されているようにタイムスタンプ プロパティが定義されているベース イベント タイプから派生した POJO を使用しようとすると、同じエラーが発生します。実際に基本型を使用すると機能しますが、他のすべてのケースでは継承に関する情報を使用するのに、この場合は継承された時間プロパティを使用しないのは奇妙に思えます。

私は何か間違ったことをしていますか？これはバグですか？それとも、意図したとおりに機能するのでしょうか...

httpadapter を使用して、esper エンジンから Web ページにデータを送信する必要があります。例に記載されている手順に従いました。どういうわけかうまくいきませんでした。プレーンな Java オブジェクトを使用して送信する必要があります。また、リクエストとレスポンス用に Web サーバーを構成する方法も教えてください。

AndroidデバイスのCEPを対象とするライブラリはありますか？たとえば、Android用のEsperバージョンはありますか？

私はJavaが初めてで、Esper CEPエンジンで使用しています。ただし、この質問は Esper とは関係なく、Java に関する質問です。

まず、私のクラス:-

基本的に、エスパーはここでは関係のないロジックに基づいて、必要なときにいつでも enter(value) と leave(value) を呼び出します。そして、 getValue() を呼び出して結果を計算します。

パーセンタイルを計算したいので、これを処理するために利用可能なすべての数値が必要です。これを行うには、これを numbers というグローバル リストに格納し、getValue() ですべての数値をDescriptiveStatisticsインスタンスに入れ、必要な統計を処理します。

私の推測では、リストを新しい DescriptiveStatistics オブジェクトとして配置するたびに、並べ替えを行う必要があります。DescriptiveStatistics のようなオブジェクトをグローバル オブジェクトとして維持する方法はありますか?

グローバル オブジェクトとして ArrayList と DescriptiveStatistics を使用する唯一の理由は、DescriptiveStatistics に remove メソッドがないことです。つまり、オブジェクトを値で削除することはできません。

実際には、このクラスには常に何百ものインスタンスが実行されており、それぞれに対して getValue() が 1 ～ 10 秒ごとに呼び出されます。現時点ではパフォーマンスの問題はありませんが、将来の問題を回避するために最適化のヘルプを探しています。

別の説明:-

私がここでやっていることは、数字のリストを維持することです。Esper は enter() メソッドと leave() メソッドを何度も呼び出して、リストに残すべき数字を教えてくれます。私の場合、これは時間ベースの集計です。過去 1 分間の数値に基づいて計算したいと esper に伝えました。

現在、この期間中に getValue() が何度も呼び出されている可能性があります。呼び出されるたびに、数値の現在の内容に基づいて計算を返すことが期待されます。

getValue() は、10 番目、50 番目、および 90 番目のパーセンタイルを計算します。パーセンタイルを計算するために、DescriptiveStatistics は数値を並べ替える必要があります。(100 個の数値の 10 パーセンタイルは、並べ替え後のリストの 10 番目の数値になります。)

そのため、DescriptiveStatistics インスタンスから任意の数値を取り出す方法を探しています。または、値を知りながらリストから数値を取り出す機能を持ちながら、中央値とパーセンタイルを提供できる他のライブラリの推奨を求めます。

DescriptiveStatistics には removeMostRecentValue() がありますが、それは私がやりたいことではありません。

重複排除に使用されるウィンドウ ポリシー以外のウィンドウ ポリシーを指定せずに、重複排除されたイベントのストリームを生成しようとしています。クエリで句を使用するoutput first everyと、目的の効果があるように見えますが、それらのクエリがストリームに直接挿入されている場合は効果がありません。

以下の例では、4 時間のウィンドウ内で各車の最初のクラクションのみを検出しようとしているとします。

ただしselect * from HonkEventDeduplicated、同じ車が 2 回続けてクラクションを鳴らした場合でも、クラクション イベントごとに発生します。

私のアプリケーションは、その内部プロセスの多くの測定を行います。たとえば、特定のメソッドの時間を計ったり、外部 Web サービス呼び出しの時間を計ったり、変化する値を持つ変数や、「状態」を持つプロセス (PAUSED、WAITING など) を持っています。

アプリケーションは 100 から 200 のスレッドを使用し、データの各ビットは特定のスレッドに関連付けられます。

このすべての情報をチャネル化して、データの有用なメトリックとグラフを生成し (理想的にはリアルタイムまたはほぼリアルタイムで)、警告をトリガーするしきい値を設定できるソフトウェアを探しています。スレッドまたはスレッドグループなどによるデータ

アプリケーションはタイム クリティカルなタスクを実行しているため、ソフトウェア/API は非常に高速であり、決してブロックされない必要があります。

アプリケーションは Java で記述されており、ソフトウェア/API も Java であることが理想的です。私が探しているのは Event Stream Processing と呼ばれるものだと思いますが、それを説明するためにどの言語を使用すればよいか本当にわかりません。

これまでに見つかったのは、エスパーと ERMA だけです。誰でも私に推薦を与えることができますか？このプロジェクトに取り組んでいるのは私だけなので、セットアップと使用が非常に簡単で、フロントエンドが機能するものを期待しています。

企業が顧客データやその他の情報を保存するために使用する顧客管理システムがあります。次のようないくつかのケースで、システムからユーザー (ビジネス オーナー) にメールを送信したいと考えています。

1. サインアップから 1 週間後、ユーザー (ビジネス オーナー) が顧客をシステムに入力しなかった場合は、顧客を追加するように促すメールを彼に送信します。これを毎週/毎月のリマインダーにします。

2. ユーザーがマイルストーン (システム内の 100 人の顧客など) に到達した場合は、お祝いのメールを送信しますが、同じマイルストーンに再び到達した場合 (削除と追加など) は送信しないでください。

編集 - 3. 休日の 1 週間前に「ハッピー ホリデー」メールを送信します (主に、ユーザーではなくイベントのプロパティへの依存を示す最も単純な例であるため、この例を示します)。

以前/将来のイベント (将来のイベントには既知の日付があります) とユーザー プロパティに基づいて、ルールを簡単に追加できるシステムが必要です。ルール エンジンとイベント処理について少し読みましたが、問題がどのクラスに属しているかはまだよくわかりません。

私が使用できるルール\イベント処理モジュールの具体的な推奨事項について聞いていただければ幸いです。DroolsかEsperのどちらかを考えていますが、どちらもかなり複雑に思えます。時間をかけてシステムに追加する前に、それが適切かどうかを確認したいと考えています。

問題があれば、Java と Hibernate を使用しています。