私は実際に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;