2. 风控系统基础:实时风控系统架构概览
实时风控系统是特征漂移监控的载体。理解其核心组件——决策引擎、特征平台与模型服务——是后续实施漂移检测的前提。本章从架构视角拆解这三者的职责与协作关系。
2.1 核心架构总览
一个典型的实时风控系统采用事件驱动架构,请求在毫秒级内依次经过接入层、特征计算、模型推理与决策输出。下图展示了核心组件及其数据流:
2.2 决策引擎:策略编排与执行中枢
决策引擎是风控系统的大脑,负责接收请求、编排规则与模型调用顺序,并输出最终决策(通过/拒绝/人工审核)。
- 规则管理:支持原子规则(如“IP 归属地非国内”)与复合规则(AND/OR/NOT 组合)。
- 策略编排:通过决策表、决策树或流程图方式定义规则执行顺序,支持 A/B 测试与灰度发布。
- 模型调用:决策引擎不直接运行模型,而是调用模型服务接口获取评分,再将评分纳入策略。
- 结果处理:输出决策码、风险等级、拒绝原因码,并触发后续动作(如限流、告警)。
关键指标:决策引擎的 P99 延迟通常要求 < 20ms,其中特征获取与模型推理占主要耗时。
2.3 特征平台:实时特征的生产与供给
特征平台是风控系统的数据中台,负责将原始数据加工为模型可用的特征。特征漂移监控的核心数据源即来自此处。
| 特征类型 | 数据源 | 计算方式 | 典型延迟 |
|---|---|---|---|
| 实时特征 | Kafka / 消息队列 | Flink / Spark Streaming 滑动窗口 | < 1s |
| 近线特征 | 数据库变更日志 | 微批处理(分钟级) | 1~5 min |
| 离线特征 | Hive / 数仓 | T+1 批量计算 | 天级 |
| 外部特征 | 第三方 API | 同步调用 / 缓存 | 10~200 ms |
特征平台需提供特征注册、特征回溯(Time Travel)与特征监控能力,确保特征口径一致且质量可控。
2.4 模型服务:推理与模型生命周期管理
模型服务负责加载风控模型(XGBoost、神经网络等)并提供高性能推理。在漂移监控场景下,模型服务还需输出模型版本与特征重要性等元信息。
- 推理引擎:支持 ONNX、PMML、TensorFlow Serving 等格式,利用 GPU/CPU 优化。
- 模型版本管理:支持蓝绿部署、金丝雀发布,便于回滚与对比。
- 特征对齐:模型服务接收特征平台输出的特征向量,需确保特征顺序与训练时一致。
- 日志输出:每条推理记录需包含模型 ID、特征快照、评分与决策时间戳,这是漂移监控的原始数据。
实践建议:在模型服务侧开启特征日志采样(如 1/10 全量特征),用于离线漂移分析,避免存储爆炸。
2.5 三者的协作关系
决策引擎、特征平台与模型服务并非孤立组件,而是通过明确的接口协议形成闭环:
- 请求入站:决策引擎接收风控请求,提取请求 ID 与基础参数。
- 特征获取:决策引擎向特征平台请求该实体(用户/设备)的实时与离线特征。
- 模型推理:决策引擎将特征向量发送至模型服务,获取风险评分。
- 策略决策:决策引擎结合规则与模型评分,输出最终决策。
- 数据回流:决策结果、特征快照与模型评分写入存储层,供漂移监控与离线分析使用。
2.6 架构对漂移监控的影响
不同的架构设计直接影响漂移监控的实施难度与精度:
| 架构特性 | 对漂移监控的影响 | 推荐做法 |
|---|---|---|
| 特征平台统一 | 特征口径一致,便于计算分布变化 | 强制所有模型通过特征平台获取特征 |
| 模型版本管理 | 可对比不同版本的特征分布差异 | 在推理日志中记录模型版本号 |
| 异步特征计算 | 特征延迟可能导致漂移误报 | 监控特征时间戳,过滤过期特征 |
| 全量日志存储 | 支持离线漂移分析与回溯 | 使用列式存储(Parquet/ORC)压缩 |
常见陷阱:特征平台与模型服务之间的特征对齐错误(如特征顺序错乱、缺失值处理不一致)是导致漂移误报的首要原因。务必在模型服务侧做特征校验。