Alertmanager-主入口main.go
Alertmanager-主入口main.go
基于v0.28
关键模块说明
API
- 入口：
api/v2/ - 功能：接收Prometheus警报、提供管理接口
- 入口：
AlertRouter
路径：
/dispatch处理流程：
1
func (r *Route) Match(lset model.LabelSet) bool
Inhibitor
路径：
/inhibit核心逻辑：
1
func (ih *Inhibitor) Mutes(lset model.LabelSet) bool
DispatchTree
- 路径：
/dispatch - 特性：多级路由树结构
- 路径：
Notification Pipeline
- 路径：
/notify - 阶段：
- GroupWait
- GroupInterval
- RepeatInterval
- 路径：
Notifier
集成：
/notify/<type>实现示例：
1
2
3
4type EmailNotifier struct {
conf *config.EmailConfig
tmpl *template.Template
}
持久化层
- Silences：
/silence - Notification Log：
/nflog - 存储后端：LevelDB/BoltDB
- Silences：
集群通信
- 协议：Gossip (memberlist)
- 同步内容：静默状态、通知日志
核心步骤拆分
flowchart TD
A["启动 main()"] --> B["调用 run()"]
B --> C["解析命令行参数"]
C --> D["初始化日志 logger"]
D --> E["解析实验性功能开关"]
E --> F["自动设置 GOMEMLIMIT/GOMAXPROCS"]
F --> G["创建数据目录"]
G --> H["初始化集群 Peer (可选)"]
H --> I["初始化通知日志 nflog"]
I --> J["初始化静默 silences"]
J --> K["启动静默和通知日志维护协程"]
K --> L["加入集群 (可选)"]
L --> M["初始化内存告警存储 alerts"]
M --> N["初始化 API 服务"]
N --> O["计算外部访问 URL"]
O --> P["配置文件热加载与订阅"]
P --> Q["注册 UI、API 路由"]
Q --> R["启动 HTTP 服务"]
R --> S["信号监听，支持热加载和优雅退出"]初始化flag
1 | var ( |
容器内实验特性开启
- 针对于容器环境下的参数设置，设置Go内存限制和EnableAutoGOMAXPROCS
1 | // 解析实验性功能开关 |
自动设置容器
1 |
|
创建数据卷
1 | // 创建数据目录 |
HA模式(可选)
1 | if *clusterBindAddr != "" { |
初始化通知日志（nflog)
1 | // ---------------------- |
初始化静默（silence）管理
1 | // ---------------------- |
启动静默和通知日志的定期维护协程
1 | // 启动静默和通知日志的定期维护协程 |
集群Peer状态监听注册完成后，正式加入集群
1 | // ---------------------- |
初始化内存告警存储
1 | // ---------------------- |
groupFn 用于API分组查询
1 | // groupFn 用于API分组查询 |
初始化API服务
1 | // ---------------------- |
计算外部访问URL
1 | // ---------------------- |
通知管道
1 | // ---------------------- |
配置文件热加载与订阅，动态重建路由、通知管道、静默、抑制等
1 | // ---------------------- |
路由前缀处理
1 | // ---------------------- |
注册UI、API路由
1 | // ---------------------- |
启动HTTP服务
1 | // ---------------------- |
信号监听，支持热加载和优雅退出
1 | // ---------------------- |
本博客所有文章除特别声明外，均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来源 Joohwan！
alipay
相关推荐
2025-07-20
Alertmanager-告警发送
Alertmanager-告警发送 基于v0.28 启动顺序sequenceDiagram participant Alert as 新告警 participant Dispatcher as Dispatcher participant Route as Route participant AggrGroup as aggrGroup participant NotifyStage as notify.Stage participant Notifier as Notifier(邮件/微信等) Alert->>Dispatcher: 新告警流入 Dispatcher->>Route: 路由树匹配 Route-->>Dispatcher: 匹配到的 Route Dispatcher->>AggrGroup: 插入/创建分组 Note over AggrGroup: run 协程定时触发通知 AggrGroup->>Noti...
2025-07-18
Alertmanager-dispatch告警分组
Alertmanager-dispatch告警分组 基于v0.28 总体流程flowchart TD A[告警流入 Alertmanager] --> B[dispatch 路由树匹配] B --> C{匹配到哪些 Route?} C -- 无匹配 --> Z[丢弃或默认处理] C -- 有匹配 --> D[分组聚合（按 group_by 标签）] D --> E[分组等待 group_wait] E --> F[分组内聚合告警] F --> G{到达 group_interval 或有新告警?} G -- 否 --> F G -- 是 --> H[触发通知管道] H --> I[通知发送（邮件/微信/钉钉等）] I --> J[分组生命周期管理] J --> K{分组内还有活跃告警?} K -- 有 --> F K -- 无 --...
2025-07-17
Alertmanager-silencer告警静默
Alertmanager-silencer告警静默 基于v0.28 总体流程sequenceDiagram participant Alert as 告警(Labels) participant Silencer as Silencer participant Silences as Silences participant Store as state(存储) participant Marker as AlertMarker Alert->>Silencer: 新告警流入，调用 Mutes(lset) Silencer->>Marker: 查询该告警指纹的静默状态 alt Marker 版本与 Silences 一致 Silencer->>Silences: 仅查询已知静默ID是否仍然有效 else Marker 版本不一致 Silencer->>Silences: 全量查询所有匹配该告警的静默 end S...
2025-07-16
Alertmanager-inhibitor告警抑制
Alertmanager-inhibitor告警抑制 基于v0.28 总体流程flowchart TD A[告警流入 Alertmanager] --> B{是否匹配抑制规则?} B -- 否 --> E[正常进入分发/通知流程] B -- 是 --> C[遍历所有 InhibitRule] C --> D{目标告警是否匹配 TargetMatchers?} D -- 否 --> C D -- 是 --> F{是否存在源告警满足 SourceMatchers 且 Equal 标签相等?} F -- 否 --> C F -- 是 --> G[该告警被抑制, 不再通知] C -->|遍历完所有规则| H{是否被抑制?} H -- 是 --> G H -- 否 --> E subgraph 规则说明 direction LR...
2024-10-27
Alertmanger-深入理解告警原理
Alertmanger-深入理解告警原理AlertManager架构图 Alert Provider：API收到来自Prometheus的告警，存储到Alert Provider 原理是内置了Map Dispatcher组件: 这是一个单独的goroutine，不断地通过订阅的方式从Alert Provider获取新的告警，并且根据YAML配置的Routing Tree将告警通过Label路由到不同的分组中，以实现告警信息的分组处理 Notification Pipeline组件:顾名思义，这是一个责任链模式的组件，它通过一系列逻辑(如抑制、静默、去重等)来优化告警质量。 在源码中，它是通过一个个实现Stage接口的具有不同功能的实例串联 起来得到的 Silence Provider组件:API层将来自Prometheus服务端的告警信息 存储到Silence Provider上，然后由这个组件实现去重逻辑处理。静默规 则用来关闭部分告警的通知 Notify Provider组件:它是Silence Provider组件的下游，会在本地记录日志，Peers的方式将日...
2025-06-05
Prometheus安全认证
Prometheus安全认证背景一般Prometheus开启端口之后就可以访问UI，缺少安全认证 Prometheus提供了 Basic Auth能力 Ref：https://prometheus.ac.cn/docs/prometheus/latest/configuration/https/ /web-config.yml：https://github.com/prometheus/prometheus/blob/release-3.4/documentation/examples/web-config.yml 1. 设置账号密码12345Centos # 下载工具yum install httpd-tools# 生成账号密码htpasswd -nB 'admin' 2.配置web-config.yml12basic_auth_users: admin: $2y$05$UKSS18ztdsUNoEuXYScr2OE1TCMe1hWnmD6JuwUi/uPTJayHIakae 3. 启动配置添加/bin/prometheus --web.c...
评论