問題タブ [wso2cep]

私は wso2ESB 4.6 で wso2BAM 2.4.1 を使用しています。

/リポジトリ/conf/etc/bam.xml

ファイルを作成し、ServiceDataPublishing 機能を有効にしました。次に、ESBのリポジトリからBAMService Data Pblishing機能をセットアップします。を設定した後、esb での作業は完了しました。Service Data Pblishing

Cassandra Explorer を使用したところ、ESB 構成で設定したストリーム名でログが Cassandra に保存されていることがわかりましたService Data Pblishing。

Service_Statistics_Monitoringツールボックスをインストールして、サービスに関するデータとリアルタイムの要求と応答の数を表示するまで、すべてがうまくいきました。

Service_Statistics_Monitoringとのストリーム名Service data Publishingが同じ (どちらもbam_service_data_publisher) であるため、データを BAM に送信するための esb ログでエラーが発生しました。ESB でストリーム名を変更すると、データ公開エラーはなくなりましたが、Service_Statistics_Monitoringツールボックスを使用してダッシュボードにデータが表示されず、下の図のようにデータが見つからないというエラーが表示されます。データは引き続き BAM に発行され、新しいストリーム名でテーブルに保存されることに言及する必要があります。

こんにちは、rabbitmq キューからメッセージを読み取る入力アダプターがあります。サーバーが起動すると、アダプターで subscribe() 呼び出しが行われることがわかります。しかし、wso2 サーバーがシャットダウンされているとき、unsubscribe() 呼び出しが行われているのがわかりません。これにより、cep の他のコンポーネントがダウンしているように見えても、アダプターは jvm が停止するまでメッセージを読み取って削除します。他の誰かがこれを見たことがありますか？

私は単純なタスクを解決しようとしています: 1. 3 つのイベントA、B、Cの発生を、最後の 10 秒間に発生した場合に関連付けたいと考えています。

したがって、Siddhi はクエリで 2 つの結合しかサポートしていないため、解決できないと思います。ドキュメントには、複数のクエリを使用して、このように結合するという提案があります

ただし、ストリーム tempA のデータはより長く存続する可能性があり、時間ウィンドウが調整されないため、これは間違った結果をもたらします。

多分私は何かが欠けています。何かアドバイス？ありがとう

WSO2 CEP カスタム関数は集計関数として機能せず、代わりにデータの各行で動作します。

入力ストリームに value1 と value2 があるとします。

• ホスト:A、Value1:1、Value2:10
• ホスト:A、値1:2、値2:20
• ホスト:A、Value1:3、Value2:30
• ホスト:A、値1:4、値2:40
• ホスト:A、Value1:5、Value2:50

これで、時間のバッチ処理とホストごとのグループ化が完了しました。そして、MEDIANを見つけるカスタム関数を作成し、組み込み関数SUMも使用しました。

ただし、グループ化後に5行すべてにSUM関数を適用しますが、カスタム関数は行ごとに呼び出されます。カスタム関数クラスのプロセス メソッドが行ごとに呼び出されていました。したがって、SUM は 15 を返しますが、私の MEDIAN 関数は最後の値 2 である 50 として出力を返します。

実行計画クエリ

カスタム関数 Java クラス スニペット

カスタム集計関数を使用できませんか、またはカスタム関数が行ごとにのみ実行されることになっている場合は???

WSO2-CEP でクエリを動的に記述する方法。PSQL ユーザーにはクエリを動的に記述するオプションがありますが、それを実現するための CEP ツールの代替手段はありますか?

使用例: 1. ストリーム内で関数とデータの両方が利用可能である場合、いくつかのオプションが必要であるか、アダプター ユーザーが動的にルールを作成できるようにする必要があるとします。

例のために。

蒸気 : 1. function1:sum、function2: avg、function3: count、value1: 1、value2: 2、value3: 3 2. function1:sum、function2: min、function3: max、value1: 1、value2: 2、value3 : 3

ルールは次のように動的に作成する必要があります。

1. .... から value1 として sum(value1)、value2 として avg(value2)、value 3 として count(value3) を選択します。
2. .... から value1 として sum(value1)、value2 として min(value2)、value 3 として max(value3) を選択します。

ありがとうガガン

WSO2 CEP サーバーを WSO2 Message Broker サーバーに接続しようとしています。

jndi.properties ファイルを作成しました。

入力イベント アダプター:

ストリーム定義:

そしてイベントビルダー:

残念ながら、WSO2 CEP サーバーは WSO2 Message Broker サーバーからメッセージを受信せず、次の例外をスローします。

[2014-11-28 13:00:00,226] INFO - {JMSEventAdaptorType} JMS 入力イベント アダプター ロード リスナー
スレッド "Thread-29" で例外 java.lang.NullPointerException
at java.util.concurrent.ConcurrentHashMap.hash(ConcurrentHashMap.java) :333) org.wso2.carbon.event.input.adaptor.jms.JMSEventAdaptorType.createJMSAdaptorListener(JMSEventAdaptorType.java:291)
で java.util.concurrent.ConcurrentHashMap.get(ConcurrentHashMap.java:988) で org.wso2. carbon.event.input.adaptor.jms.JMSEventAdaptorType.tryStartAdaptor(JMSEventAdaptorType.java:262) org.wso2.carbon.event.input.adaptor.jms.internal.ds.JMSEventAdaptorServiceHolder.loadLateStartEventAdaptors(JMSEventAdaptorServiceHolder.java:66)



org.wso2.carbon.event.input.adaptor.jms.internal.ds.JMSEventAdaptorServiceHolder$1.run(JMSEventAdaptorServiceHolder.java:43)
で java.lang.Thread.run(Thread.java:745) で

この例外のデバッグを手伝ってもらえますか?