2017-12-15 6 views
0

私は実際にWso2とSiddhiの新人です。 まずは、私がしようとしていることを説明しましょう。 私は2つのストリーム(RGとMW)に参加し、その結果を(OutStream)に挿入しようとしています。 読み取り値>しきい値を持つセンサの名前を取得しようとしています。以下は私の裁判です。私は、(OutStream)のUIパブリッシャーを定義しようとしたときに何もしないようにしようとしているかどうかを判断しようとしています。 ありがとうございます。この実行計画は必要なことをしていますか?

@Import('From_Middle_Ware:1.0.0') 
define stream MW (meta_SensorID string, SensorReadingValue double, Priority 
int); 

@Import('FromRGModule:1.0.0') 
define stream RG (meta_TempID int, correlation_InSensor string, 
correlation_OutSensor string, correlation_ActionToOutSensor double, 
Threshold double); 

@Export('OutStream:1.0.0') 
define stream Filtered (meta_SensorName string, SensorValue double); 

from MW #window.length(2000) as A 
join RG #window.length(2000) as B 
on A.meta_SensorID== B.correlation_InSensor and 
A.SensorReadingValue>B.Threshold 
select A.meta_SensorID , A.SensorReadingValue 
insert into OutStream; 

答えて

0

UIパブリッシャーの目的は、データをCEPダッシュボードにプッシュすることです。 UIパブリッシャーを追加した場合は、ダッシュボードにリアルタイムガジェットを作成し、データを表示するダッシュボードに配置することができます[1]。段階的な説明は、CEPのドキュメント[1]にあります。

出力データを見たい場合は、CEP実行端末でOutStreamイベントを出力するロガーパブリッシャー[2]を使用することをお勧めします。

[1] https://docs.wso2.com/display/CEP420/Visualizing+Results+in+the+Analytics+Dashboard

[2] https://docs.wso2.com/display/CEP420/Logger+Event+Publisher

関連する問題