問題タブ [siddhi]

WSO2 DAS サーバーから R スクリプトを呼び出したいと考えています。siddhiクエリで次のコードを書きました

Rスクリプトを呼び出す構文は正しいですか? 可能であれば、DAS コンソールでこのエラー Error message が表示される理由を教えてください。また、wso2 のリンクに従って、 https: //rforge.net/JRI/files/で JRI ファイルをダウンロードしました。

アプリケーションに CEP エンジンを統合する方法を探しています。統合するための REST API またはその他のツールが存在するかどうか、および管理コンソールからその機能にアクセスする方法を知りたいです。

ドキュメントには何も見つかりませんでした。

siddhi 3.0.3 を Java ライブラリとして使用する

タイム ウィンドウで group by を使用すると、予期しない動作が発生します。一般的な問題は、グループの正しい集計結果が得られることですが、グループごとではなく、イベントごとに 1 つの集計結果を受け取ります。

具体的には、

時間枠なしで、次のクエリを使用します。

適切なカウントと平均で、一意の EventName ごとに 1 つの結果が得られます。したがって、私の例では、15 の一意の EventName があり、それぞれの一意の EventName が 10 回発生し、合計 150 のイベントになります。EventName ごとに 1 つずつ、合計 15 の結果が得られます。予想どおり、それぞれのカウントは 10 で、正しい平均が得られます。

ただし、このクエリに時間枠を追加すると、次のようになります。

各 EventName の結果は、正しいカウントと平均を持っているため、正確です。ただし、EventName ごとに 1 つの結果ではなく、合計 150 の結果の 10 を取得します。

Esper を Siddhi に置き換えることを検討しているため、Esper を介して同様のクエリを実行し、Esper を使用して、どちらの場合も、EventName ごとに 1 つの結果の期待される出力を受け取りました。

Siddhi 3.0.3 を Java ライブラリとして使用。

クラスを拡張してカスタム集計関数を開発しましたが、メソッドが呼び出されたAttributeAggregator後に奇妙な動作が見られました。processRemove()がprocessRemove()呼び出されると、値を削除して新しい集計結果を返します。ただし、結果ハンドラーによって返されるイベントは、まだ古い値を受け取っています。ただし、processAdd()正しく動作しています。デバッグを行った後、 を呼び出すたびにprocessAdd()、 を最後に呼び出したときに返されたオブジェクトが結果イベントに含まれていることに気付きましたprocessAdd()。ただし、 を呼び出した後、イベントには、によって返された最後のオブジェクトではなく、processRemove()以前と同じオブジェクト ( last からのオブジェクト) が含まれます。processAdd()processRemove()

コレクションを維持し、そこから削除を追加し、常に同じコレクション オブジェクトを返す場合、すべて問題ありません。ただし、数値を返す集計関数の場合、各processAdd()/processRemove()はボックス化されたを返しますLongが、これは from の戻り値に置き換えられませんprocessRemove()。

組み込みの集計関数を使用しても、これと同じ動作に気付きましたcount()。

あなたのヒントで多くの問題を解決したとしても、私は Stackoverflow の初心者です。今、解決策が見つからない問題があります。WSO2 CEP と GCM を使用してプッシュ サービスを開発しています。CEP は、サブスクライブ/サブスクライブ解除要求とプッシュ イベントを処理します。サブスクリプション キーは、MySQL を使用して他の情報と共に自分のサーバーに保存されます。私の問題は、サブスクライブのステップに伴います。このステップでは、新しいサブスクリプション (挿入) と既存のサブスクリプション (更新) のいずれかを処理する必要があります。操作を簡単にするために、レコードを削除して挿入することで 2 つの操作を正規化することにしました (レコードが既に DB にある場合でも)。これを処理するために、Siddhi を使用して実行計画を作成しました。このプランでは、イベント ストリームと MySQL テーブルにリンクされたテーブル ストリームの 2 つのストリームを定義します。実行計画では、最初に、イベントから取得したキーを使用して削除が行われ、その後、イベントに含まれる情報を使用して新しいレコードが挿入されます。しかし、操作 (削除と挿入) の順序が異なるようで、サーバー上に同じ GCM キーを持つレコードが 2 つ以上ある場合がありました。テーブルに一意の制約を追加することで回避策を適用しましたが、シッディ操作で決定論的な順序を修正する方法があるかどうかを知りたいです。

よろしく

ミケーレ・デ・ローザ

ストリーム内の空の値を更新せずに MySQL Db を更新する方法はありますか? 入力データ ストリームに空の値が含まれている場合、現在、その空の値は「data_empty」値を使用して示されます。その時点で、CEP はその値 ("data_empty") で DB を更新します。私の目標は、その空の値を更新せずに残りのものを更新することです。siddhi と WSO2 CEP を使用して行うことは可能ですか。

現在、WSO2 CEP はいくつかの Http リクエストを使用してトリガーされます。ただし、トリガーされたリクエストに null 値が含まれることがあります。そのとき、CEP を使用してこれらの null 値を処理する方法。

1. Siddhi 1.x では、次のことができます。

   siddhiManager.defineStream("define ストリーム firstStream (id int, name string)"); siddhiManager.defineStream("define ストリーム secondStream (id int, name string)"); siddhiManager.defineStream("define stream thirdStream (id int, name string)");

   /li>

次に、イベントを適切なハンドラーに送信できます。バージョン3.0.4でも同じことをしたい

2. Siddhi 3.0.4 では、定義全体が次のように定義されています。

   String executionPlan1 = "define stream.." + "@info(name = 'query') " + "from ..";

   /li>

そこで、複数の ExecutionPlanRuntime を作成して、それぞれに独自のストリーム定義を作成しようとしましたが、うまくいきませんでした。midStream も定義する必要がありますか?

3. 最初のポイントで述べたように、私たちができることを達成するために、SiddhiManager に複数のクエリを追加する正しい方法を誰かが親切に提案できますか?

ありがとうございます。それでは、お元気で