esper - Esper (CEP) 查询每整分钟计算一次烛台

Question

我正在使用复杂事件处理 (Esper) 技术在我的系统中提供实时烛台计算。我在计算值方面做得很好，但是我发现很难确保蜡烛窗口从整分钟开始（对于一分钟蜡烛）并在下一分钟开始之前结束（即蜡烛 1[06:00.000 - 06:00.999]，蜡烛2[06:01.000 - 06:01.999] 等...）。

Esper 的查询语言中是否有能够提供此类功能的模式或命令？

我会很感激建设性的意见和指导。

Answer 1

在 Esper 中，您可以使用模式在零秒时每分钟触发一次，即
插入到 TriggerEvent select * from pattern[pattern[every timer:interval(1 min).] // 命名窗口以保存蜡烛数据，计算下一个蜡烛TriggerEvent select * from NamedWindowCandle .... // 删除 TriggerEvent 上的旧数据 delete from NamedWindowCandle

-rg

Answer 2

本地时间通常与交换时间不同，传递报价数据也存在延迟。分钟柱通常使用交换时间戳计算。交换时间戳值必须从滴答事件中提取。当刻度时间戳进入新分钟时，发送新的分钟柱事件。