wso2：cep：siddhi：如何使时间窗口持久化

Question

我们目前正在测试 siddhi wso2 cep。

我们需要能够重新启动 wso2 服务器进程，而不会丢失已在窗口（例如时间窗口）中累积的数据。

有没有办法让时间窗口持久化，这样服务器就可以在不丢失状态的情况下重新启动？

我们是否必须配置服务器以使用持久性？

或者我们只需要调整查询并使用事件表？

这里是我们的查询示例：

from every data= DataInStream[state == 1] -> 
   every event = EventInStream[event.no == data.no] within 24h
       insert into duplicatesOutStream data.id as id

Answer 1

您可以通过启用快照使 CEP 保持其状态。文档可以是found here。但请注意，这将“定期”（可在几分钟内配置）保持 CEP 的“整个状态”。由于这只是定期进行，因此您可能会丢失最后一次快照操作后到达的最新事件。如果您希望 cep 在崩溃后恢复，这是最简单的选择。

除此之外，没有其他方法可以使预定义的窗口持久化。但是，如果您愿意，您可以编写自己的自定义时间窗口 (documentation)，它将执行持久性并将其插入 CEP。

您也可以改用事件表。当您使用事件表时，您可以确保所有到达的事件都被持久化。 （但这种方法的一个缺点是，与 windows + 快照方法相比，这可能会影响性能）。