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