3. 告警系统基础架构：数据采集层、规则引擎层、告警分发层、阈值配置中心
一个稳定、高效的催收触达告警系统，是减少误报与漏报的物理基础。本章将系统拆解为四个核心层次：数据采集层、规则引擎层、告警分发层与阈值配置中心。理解每一层的职责与交互方式，是后续进行阈值优化的前提。
核心原则：告警系统的设计必须遵循“数据驱动、规则解耦、分发异步、配置动态”的十六字方针。任何一层的设计缺陷，都会直接放大误报或漏报的风险。
3.1 四层架构总览
下图展示了催收告警系统的标准四层架构，数据从底层采集，经过规则判定与阈值匹配，最终通过多渠道分发至风控人员或业务系统。
3.2 数据采集层：告警的“眼睛”
数据采集层负责从各个数据源实时或准实时地获取原始事件。采集的质量直接决定了后续规则判定的准确性。
| 数据源类型 | 采集内容 | 采集方式 | 常见问题 |
|---|---|---|---|
| 催收系统日志 | 案件状态变更、催收员操作记录 | Filebeat / Flume | 日志格式不一致、字段缺失 |
| 通话记录(CDR) | 通话时长、接通状态、挂断原因 | API 拉取 / 消息队列 | 延迟到达、重复推送 |
| 短信/IVR回执 | 送达状态、按键反馈、退订记录 | 回调接口 / Kafka | 回执丢失、状态码映射错误 |
| 还款流水 | 还款金额、还款时间、渠道 | 数据库 CDC / 消息队列 | 数据一致性、事务边界模糊 |
| 客户行为埋点 | APP 登录、页面浏览、投诉入口点击 | SDK 上报 / 服务端埋点 | 采样率不足、上报延迟 |
避坑提示：数据采集层最常见的误报来源是“重复数据”。例如，通话记录因网络抖动被推送两次，若规则引擎未做去重，将导致同一通电话触发两次告警。建议在采集层或消息队列侧增加幂等性标识（如 event_id + 时间戳哈希）。
3.3 规则引擎层：告警的“大脑”
规则引擎层是告警系统的核心决策单元。它接收来自采集层的原始事件流，通过预定义的规则集进行判定，决定是否产生告警。
一个成熟的规则引擎通常包含以下处理步骤：
- 事件过滤：剔除无效或白名单事件（如测试号码、内部催收员操作）。
- 阈值匹配：将事件指标与配置中心下发的阈值进行比对（如“单日催收次数 > 3”）。
- 频率控制：防止同一案件在短时间内重复触发告警（如“同一案件 5 分钟内仅告警一次”）。
- 上下文关联：结合历史事件进行综合判断（如“过去 1 小时该催收员已触发 2 次高频告警”）。
- 降噪聚合：将多条相似告警合并为一条聚合告警，减少告警风暴。
优化关键：规则引擎的判定逻辑应支持热加载。当阈值配置中心更新参数后，规则引擎无需重启即可生效，这是实现动态阈值优化的技术前提。
3.4 告警分发层：告警的“手脚”
告警分发层负责将规则引擎产出的告警事件，按照预设的路由策略，送达至对应的处理人或系统。
分发策略通常包含以下维度：
- 按告警级别：P0（紧急）→ 电话 + 即时通讯；P1（严重）→ 即时通讯 + 工单；P2（一般）→ 工单 + 邮件。
- 按业务线：M1 催收团队告警 → 发送至 M1 组长群；委外催收告警 → 发送至委外管理组。
- 按值班表：非工作时间告警 → 自动路由至当前值班人员。
- 按升级机制：告警发出后 15 分钟未确认 → 升级至上一级主管。
| 分发渠道 | 适用场景 | 优势 | 劣势 |
|---|---|---|---|
| 工单系统 | 需要跟进处理的告警 | 有闭环、可追溯 | 实时性较差 |
| 即时通讯(企微/钉钉) | 需要快速响应的告警 | 实时性强、支持交互 | 易被刷屏、信息过载 |
| 短信/电话 | P0 级紧急告警 | 强触达、不可忽略 | 成本高、频次受限 |
| 邮件 | 日报/周报汇总告警 | 容量大、便于归档 | 实时性差、易被忽略 |
3.5 阈值配置中心：告警的“神经中枢”
阈值配置中心是四层架构中唯一横向贯穿的组件。它负责管理所有告警规则的参数，并提供动态调整、版本控制、A/B 实验等能力。
下图展示了阈值配置中心的核心功能模块及其与规则引擎的交互关系：
3.6 四层协作：一次完整的告警旅程
为了更直观地理解四层如何协作，我们模拟一次“单日催收次数超限”的告警流程：
- 数据采集层：催收系统日志实时上报，包含案件 ID、催收员 ID、催收时间、催收方式。
- 规则引擎层：接收到事件后，查询阈值配置中心获取“单日催收次数上限 = 3”。引擎统计该案件当日已催收次数，发现本次为第 4 次，触发阈值。
- 规则引擎层：执行频率控制，检查该案件是否在 10 分钟内已产生过同类告警（未产生），通过上下文关联检查催收员是否处于“高频操作”状态（否），生成告警事件。
- 告警分发层：根据告警级别（P1），将告警推送至催收组长企微群，并同步创建工单。
- 阈值配置中心：记录本次告警的触发参数，供后续优化分析使用。