WSO2 스트림 상태 검사

Question

설명서 및 소스 코드에서 읽은 내용을 토대로 WSO2CEP는 수동 소프트웨어로 작동하므로 스트림 이벤트가 도착한 경우에만 작동합니다. 따라서 스트림에서 "상태 확인"을 개발하고 싶다면 직접 구현해야합니다. 내 질문은, 누구든지 그것을하는 방법에 대한 첫 걸음을 밟았습니까? 나는 어디서부터 시작 해야할지 모르겠다. InputEventAdapterFactory 또는 TimeWindowProcessor를 사용합니까? 내 시나리오는 "단순"입니다. 스트림이 x 시간에 도착하지 않으면 경고를 만들어야합니다. 이 개념이 작동

감사합니다,

마르셀로 비노

Answer 1

.

@Plan:name('ExecutionPlan') 

@Import('rss.in:1.0.0') 
define stream inStream (meta_title string, meta_description string, meta_url string); 

define trigger ThirtySecTriggerStream at every 30 sec; 

from inStream#window.length(1) 
select meta_title, time:currentTimestamp() as meta_time 
insert into table1; 

from ThirtySecTriggerStream join table1 
select meta_title, meta_time 
insert into tempStream; 

from ThirtySecTriggerStream[time:timestampInMilliseconds(meta_time)-time:timestampInMilliseconds(time:curretTimestamp())>30000] 
select meta_title 
insert into OutStream