FILTER
是否误报？
rule
Alert Manager
报警数据
TD转消息驱动
③报警显示
判断
报警数据要去哪里，哪些需要提醒与警报，哪些直接入库
Rule_Engine
rule-condition
有报警规则的tag_no集合
报警消息
报警中
时序数据库
Alert manager
有没有符合报警规则的数据
执行条件
SQL
未确认/未处置
{ \"rule_id\": \"规则id\
规则引擎
annunciation警报
实时数据库
全量
TOPIC 3
监听器
历史报警列表
websocket
已确认/未处置
查看
CONDTION
资产表
规则库
Kafka Broker
ACTION
条件
数据路由
执行器
报警库
规则解析器
部分
alarm报文
警报与弹框数据队列
已确认/已处置
抑制中
rule-action
msg
true
未确认/已处置
自动更新
处理中
确认
Rule-Parse Scheduler
实时报警列表
抑制改变提示和通知策略
车间3..N：驱动
1：N
推报警
实时数据
规则配置
报警状态
rule-info
动作
结束
TOPIC 2
过滤条件
告警库
修改数据状态
报警表
车间2：驱动
OSI PI 转消息驱动
②规则处理
拉报警
警报声音
是不是误报，是否重复报警？要不要触发报警数据
判断条件
处置
{ \"shop_id\": \"车间id\
抑制
处理
false
{ \"alarm_Id\": \"报警ID\
警报列表
延时队列
规则自动更新与条件封装
数据流
有延时规则的
车间1：驱动
TOPIC 1
消费
有报警规则的asset_id集合
①规则设置
弹框提醒
④ 报警处置
修改rule
处理状态
报警抑制
alert提醒
已处理
asset_id—》tag_no—》rule_id—》expression
Alarm message
开始
规则表
