問題タブ [siddhi]

2 つのストリームがstreamAありstreamBます。それぞれにstreamAID があり、一致するイベントにstreamBは同じ ID があります。

たとえば、1 分間のスライディング ウィンドウの後、streamAどの ID からの ID が入っていないかを知りたいです。streamB

私はこれを試しましたが、うまくいきませんでした:

from streamA as A join streamB#window.time(1 min) as B on A.id == B.id select S.Id insert expired events into streamC;

これを解決する方法を教えてください。

Web サービス (REST) があります。ストリームにイベントが来るたびに WS を呼び出したいです。

Siddhi の拡張機能を作成し、Java から Web サービスを呼び出す必要がありますか?

Web サービスを呼び出すために Java が必要な場合、"Aggregate Function" を拡張する必要がありますか?

シッディには、Web サービスを呼び出すために使用できる命令が存在しますか?

次は私の WS のサンプルです。

http://72.37.125.125:3000/phishing?url=www.innerjoin.co

コメントしてくれてありがとう

siddhi 拡張機能を作成するための Java プログラムがあります。コードは次のとおりです。

そして私の Custom.siddhiext:

私の ExecutionPlan では、次のコードを使用しています。

custom.siddhiext ファイルは /repository/components/lib にありますが、次のエラーがあります。

なんで ？

siddhi を拡張したいのですが、mi Java コードは次のとおりです。

シディエクスト:

JAR を生成しました。場所は C:\wso2\wso2das-3.0.1\repository\components\lib です。

siddhi の「swordurl」を使用できます。

しかし、実行計画を実行すると、次のエラーが発生します。

このエラーは、Siddhi への外部依存関係を使用すると常に発生します。なぜ ？

この場合、次の外部依存関係を使用します。

(私はエスパーからシッディにジャンプしています)

同じストリームに複数のクエリを展開しようとしています。ここの例https://docs.wso2.com/display/CEP400/Using+Siddhi+as+a+Libraryは、1 つの ExecutionPlan でまとめてストリームにクエリをデプロイする方法を示しています。では、クエリを同じ実行プラン、つまり同じストリームに追加したい場合はどうすればよいでしょうか?

これを文法的に Java コードで行うことに興味があります。

アップデート

既存の実行計画にクエリを追加したいと考えています。これは、ストリームが到着する前ではなく、ストリームが到着している間を意味します。回答として投稿された例を使用：

カスタムマップされたストリームをインポートするだけで、単純な siddhi クエリを作成しようとしています。しかし、ストリームをインポートしてクエリを検証するとすぐに、エラーが発生します。

ただし、私の完全なクエリは

私が望むのは、1 分間のログ内のレコード数をカウントし、時間をエクスポートして出力ストリームにカウントすることだけです。しかし、最初の行でもエラーが発生します。bro私の入力は、 IDのログ ファイルですssh.log。そのサンプル レコードは次のようになります。 {"ts":"2016-05-08T08:59:47.363764Z","uid":"CLuCgz3HHzG7LpLwH9","id.orig_h":"172.30.26.119","id.orig_p":51976,"id.resp_h":"172.30.26.160","id.resp_p":22,"version":2,"client":"SSH-2.0-OpenSSH_5.0","server":"SSH-2.0-OpenSSH_6.6.1p1 Ubuntu-2ubuntu2.6","cipher_alg":"arcfour256","mac_alg":"hmac-md5","compression_alg":"none","kex_alg":"diffie-hellman-group-exchange-sha1","host_key_alg":"ssh rsa","host_key":"8d:df:71:ac:29:1f:67:6f:f3:dd:c3:e5:2e:5f:3e:b4"}

単純な SiddhiQL クエリを使用して、分のエントリとこれらのタイムスタンプまで同じタイムスタンプを持つレコードの数を取得しています。クエリは次のとおりです。

それは私にエラーを与えますmismatched input 'group' expecting {'*', '+', '-', '/', '%', '<', '<=', '>', '>=', '==', '!=', AS, OR, AND, IN}。group byこの文脈で句の何が問題になっていますか?

グループの結果をクエリで消化するのに問題があります。という名前のソース ストリームにintermediateStreamはデータがあります

SIDDHI クエリは

出力が次のようになることを期待しています

しかし、代わりにそれは戻ります

助言がありますか？