BeeX 告警中心方案

1. 目标

2. 总体架构

3. 监控范围

4. 告警统一模型

所有来源转换为同一 Alert 模型。

5. 告警接入接口

第一版按来源拆接收接口，内部统一映射为 Alert。

POST /api/v1/alerts/ingest/cloud-monitor
POST /api/v1/alerts/ingest/uptime
POST /api/v1/alerts/ingest/business
POST /api/v1/alerts/ingest/ai-ops
POST /api/v1/alerts/ingest/manual

业务服务上报样例

{
  "source": "BUSINESS",
  "env": "id-test",
  "countryCode": "ID",
  "level": "P1",
  "targetType": "JOB",
  "targetName": "tiktok-order-sync",
  "title": "TikTok 订单同步延迟",
  "message": "最近一次成功同步已经超过 2 小时",
  "metricName": "last_success_age_minutes",
  "metricValue": 128,
  "threshold": 120,
  "occurredAt": "2026-07-22T08:00:00Z"
}

响应样例

{
  "success": true,
  "data": {
    "alert": {
      "alertId": "alr_mx123",
      "status": "OPEN",
      "repeatCount": 3
    },
    "accepted": true
  }
}

管理后台代理接口

GET  /api/v1/admin/alerts
GET  /api/v1/admin/alerts/summary
GET  /api/v1/admin/alerts/{alertId}
POST /api/v1/admin/alerts/{alertId}/ack
POST /api/v1/admin/alerts/{alertId}/resolve
POST /api/v1/admin/alerts/{alertId}/mute

6. 去重、静默与升级

7. 飞书转发

飞书消息由告警中心发出。

BeeX 告警 [P0]
环境: id-test
来源: UPTIME
对象: API / api-id-test
状态: OPEN
标题: API Health Down
消息: https://api-id-test.beexofficial.com/actuator/health 连续 2 次失败
首次发生: 2026-07-22 16:00:00
最近发生: 2026-07-22 16:02:00
重复次数: 2
后台查看: https://admin.beexofficial.com/alerts.html

8. 管理后台页面

后台新增“告警中心”，调用 ai-ops-worker Alert API。

后台接口

GET  /api/v1/alerts?env=id-test&status=OPEN&level=P0
GET  /api/v1/alerts/{alertId}
POST /api/v1/alerts/{alertId}/ack
POST /api/v1/alerts/{alertId}/resolve
POST /api/v1/alerts/{alertId}/mute
GET  /api/v1/alerts/stats/summary

9. CloudMonitor 接入方式

阿里云云监控报警回调地址：

https://ai-ops.beexofficial.com/api/v1/alerts/ingest/cloud-monitor

10. Uptime Kuma 接入方式

Uptime Kuma 通知 Webhook：

https://ai-ops.beexofficial.com/api/v1/alerts/ingest/uptime

11. 业务服务接入方式

业务服务 OpsMonitorService 调用 Alert Ingest API。

12. 数据库设计

告警中心使用 ai-ops-worker 独立数据库。

CREATE TABLE alert_records (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  alert_id VARCHAR(64) NOT NULL UNIQUE,
  source VARCHAR(32) NOT NULL,
  env VARCHAR(32) NOT NULL,
  country_code VARCHAR(8),
  level VARCHAR(8) NOT NULL,
  status VARCHAR(16) NOT NULL,
  target_type VARCHAR(32) NOT NULL,
  target_name VARCHAR(128) NOT NULL,
  title VARCHAR(255) NOT NULL,
  message TEXT,
  fingerprint VARCHAR(255) NOT NULL,
  first_seen_at DATETIME NOT NULL,
  last_seen_at DATETIME NOT NULL,
  repeat_count INT NOT NULL DEFAULT 1,
  acked_by VARCHAR(128),
  acked_at DATETIME,
  resolved_by VARCHAR(128),
  resolved_at DATETIME,
  muted_until DATETIME,
  raw_payload JSON,
  created_at DATETIME NOT NULL,
  updated_at DATETIME NOT NULL,
  KEY idx_status_level (status, level),
  KEY idx_fingerprint_status (fingerprint, status),
  KEY idx_env_source (env, source),
  KEY idx_last_seen (last_seen_at)
);

CREATE TABLE alert_events (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  alert_id VARCHAR(64) NOT NULL,
  event_type VARCHAR(32) NOT NULL,
  message TEXT,
  operator VARCHAR(128),
  raw_payload JSON,
  created_at DATETIME NOT NULL,
  KEY idx_alert_id (alert_id)
);

CREATE TABLE alert_notifications (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  alert_id VARCHAR(64) NOT NULL,
  channel VARCHAR(32) NOT NULL,
  recipient VARCHAR(255),
  status VARCHAR(32) NOT NULL,
  error_message TEXT,
  sent_at DATETIME,
  created_at DATETIME NOT NULL,
  KEY idx_alert_id (alert_id)
);

13. 安全与权限

14. 落地步骤