用途:为数据库迁移构建可观测性与实时监控方案,覆盖实时数据同步(CDC)、指标采集、告警系统和可视化看板。适用于迁移可观测性、实时监控相关任务,或需要该领域最佳实践与检查清单时;与迁移可观测性无关的任务不适用。
主要能力:
- 可观测的 MongoDB/Atlas 迁移:以类封装迁移流程,接入 winston 日志与 prom-client 指标,采集迁移耗时直方图、已处理文档计数器、迁移错误计数器,并按 version、status、collection、error_type 等标签区分,迁移在事务会话中执行并记录成功/失败。
- 基于 Debezium 的变更数据捕获:以 Python 类管理 CDC 可观测性,使用 Kafka 消费与生产,定义事件处理总量计数器、消费者积压(lag)与复制延迟秒数等 gauge 指标,消费 database.changes 主题。
- 指标、日志、告警与看板组合,实现异常检测与自动化告警。
使用方式:作为技能指令使用,需求以 $ARGUMENTS 传入。示例代码依赖 mongodb、winston、prom-client、kafka、prometheus_client 等库,命令与代码需保持原样。
限制:资料仅给出前两部分示例,CDC 管道后续步骤、告警规则、仪表盘配置及具体部署方式暂未提供;未说明支持的数据库范围、性能指标、定价与平台信息。