WSO2 CEP - 插入多个流

Question

在 SiddhiQL 中如何插入具有相同条件的多个流？

当我有两个相关事件（事件 1 和事件 2）并且想要 在 streaA 中插入事件 1； 在 streamB 中插入 event2； 在 streamC 中插入抽象事件。

我必须写三个 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;