一、动态规则模块

二、大数据任务告警处理模块

1、基于Flink的广播流及时获取到最新的告警规则数据并将数据写入Flink的状态存储State中。

2、基于Flink的事件驱动特性来一条数据即触发处理，根据上报数据从State中获取对应的规则进行告警判断。

3、如果满足告警规则中的条件则进一步判断是否超过连续告警时长，此判断需要从State中获取对应设备的历史告警数据如果超过说明已不符合连续时长条件需要将历史数据清空并设置当前告警数据为第一条历史数据。如果没超过则进一步判断是否满足连续告警条件，如果不满足则将当前告警数据追加到历史告警数据，如果满足则直接输出告警。这里很好的借助了Flink状态存储的特性，将中间数据直接写入State无需借助外部存储简化了程序的复杂度同时也提高了处理效率。