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