如何利用flink CEP检测趋势e

Question

我是新来的Flink CEP。对于我们的一个用例，我们需要为温度传感器输出实现流分析。如果温度持续升高30分钟，需要向操作员发出警报。我浏览了模式API，但无法找到在模式中对此建模的方法？请建议使用模式检测此模式的可能方法。

Answer 1

这里有两种可能的选择，你可以考虑。

首先，在cep中使用迭代条件，检查当前事件的温度是否高于所有先前接受的事件。在文档IterativeCondition中有一个这里示例。关键是调用ctx.getEventsForPattern，然后将当前事件与先前接受的事件进行比较。

第二种解决方案取决于具体的用例，但也许您可以使用滑动窗口在30分钟的窗口中收集元素，并根据数据收集的频率进行一些幻灯片。然后，应该很容易根据时间戳对元素进行排序，并验证窗口中是否有增长趋势。