siddhi ( http://siddhi-cep.blogspot.com/ ) / WSO2 是否具有处理类似于以下内容的查询的功能
1) 5 次错误后成功
2) 5 个错误,5 个致命,1 个成功
可以假设存在时间窗口
谁能提供一个例子?
siddhi ( http://siddhi-cep.blogspot.com/ ) / WSO2 是否具有处理类似于以下内容的查询的功能
1) 5 次错误后成功
2) 5 个错误,5 个致命,1 个成功
可以假设存在时间窗口
谁能提供一个例子?
您可以使用 siddhi 的模式或序列实现来完成此任务(模式和序列是两种不同的实现,请参阅文档)...请参阅 [1] 和 [2]...
[1] http://docs.wso2.org/wiki/display/CEP210/Patterns
[2] http://docs.wso2.org/wiki/display/CEP210/Sequences
@DarkCthulhu:Siddhi 是 WSO2 CEP 的查询处理引擎...(有关此的更多信息,请参阅:http ://docs.wso2.org/wiki/display/CEP210/Introduction+to+SiddhiQL )
谢谢,
莫汉
@萨比尔:
关于您关于我们是否可以应用 Pattern.count(...) 的查询,您是否在询问是否可以在与模式匹配的字段上应用 count、avg、max、min、sum 等聚合?
如果是这样,答案是否定的,当前版本的 Siddhi 是不可能的。
如果您想要的只是简单地计算编号。给定 ip 的错误,您可以尝试这样的查询。
from NetFlowStream[status == 'ERROR']#window.time(5 min)
insert into ErrorNetFlow ipAddr, count(ipAddr) as ipAddrCount
group by ipAddr
有关为 Siddhi 编写窗口查询的更多信息,您可以参考http://docs.wso2.org/wiki/display/CEP210/Windows 。
谢谢,
拉桑塔