发布[告警]检测事件
如果长度大于0
font color=\"#262626\" style=\"\
// 将需要新增的[指标DTO数据]加入集合中MonitorMetricsDTO monitorMetricsDTO = generateMonitorMetricsDTO(metricsPerData);metricsPerData.setMonitorMetrics(monitorMetricsDTO);monitorMetricsDTOList.add(monitorMetricsDTO);
集合A
CollectorData.resolveCollectorData(consumerRecordWrapper.getJsonData());
集合C
1.替换[采集器上数指标]为[系统映射指标]2.如果[指标]在font color=\"#ed77b6\
1.doris数据库 monitor_alarm2.mysql数据库 cmdb_resource_info
结束
1.处理[告警确认]2.处理[数据无值]3.处理font color=\"#ec7270\
doris数据库insert1.monitor_metrics2.monitor_metrics_key_metrics
集合B
1.判断[生效时间]2.判断[空值数据]3.根据[策略数据]验证4.根据[策略数据关系]验证5.font color=\"#ec7270\
发布[指标数据表]插入事件
1.接收[指标]数据2.检验格式化[指标]数据
1.获取[告警规则]2.根据[告警规则]判断告警3.搜集[告警/恢复]font color=\"#ec7270\" style=\"font-size: inherit;\
Kafka
1.根据[资源Id]查询[告警信息]集合2.保存[告警/恢复]数据3.判断是否需要发布[告警通知]
// 将需要检测的[指标数据]加入集合中metricsPerDataList.add(metricsPerData);
font color=\"#314aa4\
如果存在告警或者恢复告警
发布[告警变更]事件
1.根据[模型Id]获取采集器[指标映射]信息2.根据[资源Id]获取[监控策略][指标信息][告警策略]
// 获取[告警规则]PolicyParam policyParam = PolicyParam.generateAndCheck(cmdbMonitorAlarmPolicy.getPolicyParam());
// 判断告警AlarmData alarmData =font color=\"#314aa4\
