报警规则引擎业务逻辑

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