問題タブ [siddhi]

カスタム実行計画ビルダーの機能を備えたツールの開発に取り組んでいます。したがって、このツールを使用することで、エンド ユーザーは WSO2 CEP 内で多数の実行計画を作成できます。これについては、次の3つの懸念があります。

1) CEP に多数の実行プランがある場合、パフォーマンスに大きな影響はありますか? 約 100,000 の実行計画が存在する可能性があります。

2) 多数の実行計画がある場合、それらをグループ化する方法は?

3) 最後に、ツールの UI に実行プランをロードします。そのため、エンド ユーザーはそれらをカスタマイズできます。実行計画パーサーがあるので、それを渡してオブジェクトとして取得できます。または、実行計画をUI（Javaプログラム）にロードすることに関するその他の提案。

ありがとう

WSO2 CEP v4.1.0 を使用して、ストームをサポートする簡単な実行計画を作成しました。ただし、シッディでウィンドウ機能を使用すると、いくつかの例外が発生します。また、ストームを使用してストリームとテーブルを結合することもできません。これを解決するにはどうすればよいですか? それに代わるものはありますか。

実行計画

CEP による与えられたエラー

例外: 無効な分散クエリが指定されました。XML ストーム クエリ プランへの変換中にエラーが発生しました。実行計画: ExecutionPlan テナント: -1234。クエリのデプロイ中にエラーが発生しました: @name('query1') @dist(parallel='8', execGroup='Filtering') from InputStream#window.time(1 sec) select id as id, param3 as param3 insert into OutputStream Parallelism hasウィンドウ、結合、およびパターン クエリの場合は 1 になります。

私はシッディが初めてで、いくつか質問があります。

1. SiddhiManagerはスレッドセーフですか? JVM ごとに 1 つの共有インスタンスを使用することをお勧めしますか?

2. 実行時にストリームを定義してクエリを追加する方法は? 新しいExecutionPlanRuntimeインスタンスを作成するsiddhiManager.createExecutionPlanRuntime(plan)しかないようです。また、ストリームとクエリを再定義する方法は?

3. QueryCallbackのinEvents とremoveEventsは何ですか?

   /li>
4. ストリームとクエリがたくさんある場合、Siddhi はどのようにスケーリングしますか?

ありがとう！

スタンドアロン ライブラリとして Siddhi CEP 3.0.2 を使用しています。連続するイベントを関連付けて変更を検出するために、以下のストリームとクエリ定義を使用した単一の実行プランがあります。カスタム関数呼び出しを呼び出しています。ストリーム定義で言及されているオブジェクト属性は、カスタム Java オブジェクトおよび java.util.Map オブジェクト タイプです。

すべてのイベントが定期的に 5 分間発生すると、CPU 使用率が 1 秒間で約 40% から 50% に達し、徐々に低下することがわかりました。しかし、この CPU 使用率は 5 分ごとに増加しています。

パターン クエリの使用方法に問題があります。これについて何か助けはありますか？

postgres ブラックリスト テーブルがあります。このテーブルをロードし、WSO2 DAS のイベント テーブルを使用して結合を実行したいと考えています。

しかし、クエリでブラックリストの食べることはできません。

これは私のサンプルコードです:

これはエラーです：

「ID「Trazablack」のストリーム/テーブル定義は、実行計画「ExecutionPlan」で定義されていません」

それが可能だ？

siddhi から postgres テーブルを読みたいのですが、トリガーを使用しています。

しかし、問題があります。クエリは 10 分ごとに実行され、新しいイベントが到着したときに実行する必要があります。

これは可能ですか？