阈值作业消费流程

恢复事件

syncRulesyncObject

initObjectinitRule

指标阈值消费流程图

指标阈值分析

缓存对象可以细看代码关注缓存存储

消费dw_metric_model心跳数据则发超时未上报

删除阈值

这里是启动初始化加载cep_config表中数据

同删除阈值

启动阈值

sync

start

同创建阈值

资源绑定策略

dw_metric_model

level0

cep_config_rule_xxxxxxxcep_config_object_xxxxxxx

停止阈值

北京分行的数据有同步作业同步到上海kafka中

uyun.store.event.origin

monitor_state

1.更新cep_config关系数据 type=1 id=triggerId+objectId data中action为delete 并往kafka中写cep_config_object_xxxxxxx

1.写入cep_config关系数据 type=1 id=triggerId+objectId data中action为create 并往kafka中写cep_config_object_xxxxxxx

1.cep_config表 rule规则物理删除 type=0 id=triggerId  并往kafka中写cep_config_rule_xxxxxxx  action delete 此处消费时已经通过triggerId  删除了规则和关系缓存 不会写cep_config_object_xxxxxx topic2.cep_config表  关系数据物理删除 type=1  id=tiggerId+ObjectId

指标阈值启动加载以及告警发送

基础资源告警

这里是异步加载monitor编辑阈值，绑定资源后异步同步消费kafka将数据写到缓存中

超时未上报告警

alert_model

编译规则模板EsperSingoleton.deploy方法

更新cmdb表

修改阈值

monitor端消费

monitor端相关操作与cep_config表数据库关联

1.cep_config表rule规则更新 type=0 id=triggerId 并往kafka中写cep_config_rule_xxxxxxx action update

level=0

原始事件模型

判断执行最终走MonitorUtil.eventAction发告警进入方法优先写monitor_state 

消费调用规则模板

1.cep_config表rule规则写入 type=0 id=triggerId  并往kafka中写cep_config_rule_xxxxxxx action create（2.若当前策略已经关联资源 则也会写入关系数据 type=1 id=triggerId+objectId data中action为create 并往kafka中写cep_config_object_xxxxxxx）

data.containsKey(\"type\")

更新monitorrule_state表

新建阈值

资源取消策略绑定