一种基于规则引擎的告警方法、系统、存储设备及终端

    公开(公告)号:CN114595126A

    公开(公告)日:2022-06-07

    申请号:CN202210301927.3

    申请日:2022-03-24

    IPC分类号: G06F11/32 G06F11/30

    摘要: 本发明提供的一种基于规则引擎的告警方法、系统、存储设备及终端,所述方法包括:采集多个设备的实时数据,并将实时数据发送到Kafka中;设置每个设备的告警规则并进行配置形成相应设备的规则数据,并将规则数据发送到Kafka中;以及将全部规则数据存储至元数据库中;数据流引擎Flink从Kafka中订阅实时数据与规则数据,对实时数据进行规则匹配,根据触发条件、收敛条件、复归条件,发出/不发出告警消息;数据流引擎Flink将告警消息发送到Kafka中;告警存储和消息推送引擎从Kafka中订阅告警消息;按照已配置的消息推送策略,推送给用户;本发明具有数据处理效率较高的有益效果,适用于监控告警领域。