wso2 - WSO2 CEP - 複数のストリームへの挿入

Question

SiddhiQL では、同じ条件で複数のストリームに挿入するにはどうすればよいですか?

相関する 2 つのイベント (event1 と event2) があり、event1 を streamA に挿入したい場合。event2 を streamB に挿入します。streamC に abstractEvent を挿入します。

3 つの Siddhi クエリを作成する必要がありますか?

ありがとうございました。

Answer 1

はい、イベントを複数のストリームに挿入するには、同じ実行プランに複数の Siddhi クエリを記述する必要があります。各ストリームのイベントを選択するロジックは、フィルターを使用して実行できます。次のケースでは、フィルターを使用して、奇数の meta_id イベントを stream1 に、さらには stream2 に挿入しています。

@Plan:name('ExecutionPlan')

@Import('test:1.0.0')
define stream test (meta_id int, meta_name string);


from test[meta_id % 2 == 0]
select * 
insert into stream1;


from test[meta_id % 2 == 1]
select * 
insert into stream2;