WSO2CEP:Sidhi QL:我可以在一个执行计划中访问多个属性吗

Question

我对WSO2 CEP Siddhi QL很陌生，我需要用多个参数分析多个节点的事件。西迪可能这样吗？如果是，我该如何实现它。？

执行计划

@Plan:name('ExecutionPlan')
@Import('InputStream:1.0.0')
define stream InputStream (node string, param1 int, param2 double, param3 string, param4 string, param5 string, param6 string, param7 string,......,param120 string);
@Export('outputStream:1.0.0')
define stream OutputStream (val1 string, param3 string);
from InputStream [(node == 11 AND Param2 < 110) 
AND 
(node == 12 AND Param3 > 40)
AND 
(node == x AND Paramx > some value)] #window.time(1 sec)
select node as val1, param2 as param2, param3 as param3  
insert into OutputStream;

因为我必须等待以获得其他节点的数据。如何处理多个事件。。？

Answer 1

我认为Siddhi不可能做到这一点。Siddhi将根据"每个事件"进行处理，因此，无法评估需要多个事件输入的过滤器。

然而，如果你知道事件到达顺序(即节点11后面跟着节点12，等等)和节点计数，那么你可以使用Siddhi模式来实现这一点；

例如：

from every( e1=InputStream[node == 11 AND Param2 < 110] ) -> e2=InputStream[node == 12 AND Param3 > 40] -> eX=InputStream[node == X AND ParamY > ZZ]
select e1.node as val1, e1.param2 as param2, e2.param3 as param3
insert into OutputStream;

Answer 2

可以通过将流拆分为多个来访问具有多参数的多节点。这是通过使用WSO2中的模式来完成的。

from every (e1=InputStream) -> (e2=InputStream)-> e3=InputStream[(e1.node == '11' AND e1.param1 > 500 AND e1.param2 > 1000 ) AND (e2.node =='12' AND e2.param3 > 200 AND e2.param1 < 100)] within x mins