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
有没有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