WSO2 CEP 事件生命周期

WSO2 CEP event lifecycle

有没有document/article解释WSO2 CEP中的事件生命周期? 我不太明白事件是如何从事件流中丢弃的。

谢谢, 雨果·卡拉多

事件将被立即丢弃。基本流程是流将接收来自和接收者的事件,它会立即将事件推送给发布者而不存储。如果你想收集特定时间段的事件,你可以在 Siddhi 执行计划 [1].

中使用时间 windows 之类的东西

在接下来的 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