恢复事件
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表
新建阈值
资源取消策略绑定
