0
저는 실제로 Wso2와 Siddhi가 처음입니다. 먼저, 내가 뭘하려고하는지 설명하겠습니다. 두 개의 스트림 (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;