complex-event-processing

-1熱

1答えて

リアルタイムまたはほぼリアルタイムでイベントを処理するために必要なイベント処理アプリケーションがあります。 1分に5000-10000件のメッセージが得られることが期待されます。受信イベントを処理するには、追加のデータ要素を取得する必要があります。例のために、財政領域を考えてみましょう。したがって、入ってくるイベントはトランザクションであり、処理はいくつかのビジネスルールを通じてそれらを検証する

0熱

1答えて

最新のAとすべてのBとフィルタを一致させるEPLパターン

最新のAに続いて& all B（prop1 = A.prop1）が続くEPLパターンを検索しようとしています。私は、{A1、B1}、{A1、B2} {A3、B3} {A4、B4にマッチするパターンを探していEsper's documentationで定義されるように同じ配列を使用 ... A1 B1 C1 B2 A2 D1 A3 B3 E1 A4 F1 B4 }彼らはすべてprop1の値が同じ

0熱

2答えて

Apache Flinkパターン条件リストあり

私はパターンを書きました。私は条件（jsonからgettinのルール）のリストを持っています.Data（json）は、フォームのカフカサーバーに来ています。このリストでデータをフィルタリングしたいのですが。しかし、それは動作していません。どうやってやるの？私はキーストリームとアラームについてはわかりません。このような仕事をすることはできますか？メインプログラム： package cep_kaf

2熱

1答えて

Visual Studio用のAzureストリーム分析ツール：集約クエリ実行時のエラー - 「オブジェクト参照がオブジェクトのインスタンスに設定されていません」

ドキュメントUse Azure Stream Analytics tools for Visual Studioに従っており、Visual StudioでAzure Stream Analyticsプロジェクトを作成できました。その後 [ { "Driver": "Lewis", "Speed": 0.8275496959686279, "Accele

0熱

1答えて

Siddhi Jarがカーボンコンソールに表示されない

WSO2 CEPでは、私はある計算をしているカスタム関数を持っています。次のようなクエリがあります上記の入出力イベントストリームをCarbon Consoleに表示することはできますか？ jarファイルをrespository/components/dropinsフォルダに置こうとしましたが、カーボンコンソールでストリームを見ることができません。

0熱

1答えて

は私が <p>FLINK</p>で検出されている警告の値を印刷しようとしています

（）関数作り付けのプリントを使用せずにApache FLINKでDataSteam の個々の要素を印刷することができます//一致した各警報パターンに対する温度警告を生成します誰かが私に言うことができる私は、 Rack id = 99 and temprature = 76.0 （のEventSource機能ののtoStringあたりなど）、以下のような出力を取得しています DataStrea

0熱

1答えて

warnings.print（）（最初の最後のイベント）逆の順序でイベントを出力しますが、ApacheのFLINK CEPで最初のイベントをexceptsで

私はパターンの下に使用してFLINKに> 10あるすべての一時イベントをフィルタしようとしています、 Pattern<MonitoringEvent, ?> warningPattern = Pattern.<MonitoringEvent>begin("first") .subtype(TemperatureEvent.class) .where(new Filt

2熱

2答えて

エスパパターンタイマー：interval（）が動作しません

私はこの基本的なPOCコードを持っています。私はイベントが公開されているのを見ることができますが、リスナーには何の警告も出ません。以下のコードでは、pattern1またはpattern2のいずれのステートメントにも警告がありません。設定のsetInternalTimerEnabledはデフォルトではTrueですが、コードでTrueを設定しようとしましたが、同じ問題です。何か不足していますか？

-1熱

1答えて

1000+レコードをデータベーステーブルに書き込む最も効率的な方法

私たちは、当社のスタッフが一度承認したデータベーステーブルに1000以上のレコードを書き込む必要がある製品を用意しています。この数のレコードを一度に書き込む伝統的な方法は、テーブルに直接ループまたはMySQL一括挿入することです。これに加えて、私はCRONジョブによってチェックされているテーブルをいくつか持ち、一度に2000レコードで別のテーブルを更新します。私は、MySQLの一括挿入（パフォ

0熱

1答えて

エスパー - WHERE

のquestionを探していましたが、これはselect * from pattern [every (timer:interval(10 sec) and not EventX)];が必要ですが、どこのid = "001"であっても、私はWEHEREをどこに置くべきか分かりません。