监控告警逻辑

发布[告警]检测事件

如果长度大于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\