RULE BODY
调研点：OSI PI 是否支持实时数据转消息驱动
MSG1
PS: 自定义规则：对于一个设备，单变量/多变量逻辑运算、函数计算的告警规则。 实时数据：设备id（asset_id） 位号（tag_no） 数据列表（datas） 时间戳（Timestamp） 运算结果值：①逻辑运算值true\\false;② 函数计算值报警规则：①：逻辑值 等于true/false，设备XXX报警②：计算值 在哪个区间，或者大于小于哪个固定值，设备YYY报警
rulelistener规则监听器
kafka broker
开关量类报警
Action-Processor
规则解析器
先计算、再判断
业务流程
业务流程一：实时数据转消息
topic...N
rule_idrule_namerule_typealarm_typeasset_idalarm_active
编辑报警规则
(代码脚本)expressionalarm_levelalarm_contentalarm_priority
OSI PI 转消息驱动
报警展示
Alert-Manager
总体业务流程
创建规则
Group-..n
kafka Producer
应用数据源切换开关
Rule 格式(json)
纯判断
PS: 开关量规则：对于一个变量，从状态变化报警。比如异常启停、设备异常/故障等 实时数据：设备id（asset_id） 位号（tag_no） 数据（data） 时间戳（Timestamp） 开关量枚举值：0（XXX状态描述） 1（YYY状态描述） 报警规则：①：从原始值0~最新值1，设备XXX报警②：从原始值1~最新值0，设备YYY报警
报警规则名称选择报警类型
报警类型
MSG2
遵循
MSG..
选择资产与点位
consumer2
自定义类报警
consumer1
消费性能评估报告
data structure
Rule-Parse-Processor
Rule-Engine
写入性能评估
PS: 越限规则：对于一个变量，只可能越一种限，因此只产生一种越限报警实时数据：设备id（asset_id） 位号（tag_no） 数据（data） 时间戳（timescale）越限值： 最小值（minimum ）、低低限（low_low）、低限（low）、高限（high）、高高限（high_high)、maximum最大值越限规则：① min< data < low_low 低低限报警②low_low < data < low 低限报警③low < data < high 正常④high< data < high_high 高限报警⑤high_high < data < maximum 高高限报警
partition2
Group-1
Group-2
ACK
Condition-Processor
topic-1
consumer3
alarm_sound_urlalarm_countfocus_tag_listalarm_notice_delayalarm_intervalalarm_dead_zone
partition1
PUSH
报警分发
规则执行器
kafka Broker实时流数据
越限类报警
保存
RULE HEAD
③
partition..N
报警通知
性能评估点
partition3
1.topic设置规则，partition、replica、group、consumer2.消息体封装规范
创建规则流程
TD转消息驱动
条件判别器
RULE FOOT
partition4
制定报警触发与延迟机制
规则库
数据流
OSI PI实时数据库
规则
TD时序数据库
②
选择报警等级与制定报警内容
实时数据库
实时数据源
报警规则管理
PULL
