是否有任何文档/文章解释 WSO2 CEP 中的事件生命周期?我不太明白事件是如何从事件流中丢弃的。
谢谢你,雨果卡拉多
是否有任何文档/文章解释 WSO2 CEP 中的事件生命周期?我不太明白事件是如何从事件流中丢弃的。
谢谢你,雨果卡拉多
事件将立即被丢弃。基本流程是流将接收来自和接收者的事件,它会立即将事件推送到发布者而不存储。如果您想收集特定时间段的事件,您可以使用 Siddhi 执行计划 [1] 中的时间窗口之类的东西。
在以下 Siddhi 查询中,它收集 10 分钟的事件并通过计算平均流插入 AvgTempStream。在这种情况下,事件将在内存中存储 10 分钟。
from TempStream#window.time(10 min)
select avg(temp) as avgTemp, roomNo, deviceID
insert all events into AvgTempStream;
[1] https://docs.wso2.com/display/CEP400/SiddhiQL+Guide+3.0#SiddhiQLGuide3.0-Window