1. 课程导论:信用额度定价的业务背景、流式决策的价值、课程目标与学习路径
1.1 信用额度定价的业务背景
在零售信贷与信用卡业务中,信用额度定价(Credit Line Pricing)是指金融机构根据申请人的信用风险、收入水平、负债情况以及市场策略,动态确定授信额度与对应利率的过程。传统做法依赖离线批量评分卡与固定利率表,更新周期通常为 T+1 甚至 T+7,无法响应客户实时行为变化。
当前业务痛点集中在以下三个方面:
| 痛点 | 传统方案 | 业务影响 |
|---|---|---|
| 时效性滞后 | 日终批量跑分,次日生效 | 错失优质客户实时提额机会,流失率上升 15%~20% |
| 定价粒度粗 | 按产品线统一定价,缺乏个体差异化 | 高风险客户定价不足,低风险客户定价过高,逆向选择 |
| 模型更新慢 | 季度或半年度重新训练 | 无法捕捉消费行为突变与宏观经济波动 |
关键指标: 实时定价决策可将客户响应速度从小时级压缩至毫秒级,同时通过动态风险校准将不良率降低 8%~12%。
1.2 流式决策的价值
流式决策(Streaming Decision)将传统批处理流程拆解为事件驱动的实时管道:客户行为事件(如刷卡、还款、额度使用率变化)一经产生,立即触发特征计算、模型推理与定价策略执行。其核心价值体现在:
- 毫秒级响应: 从事件到达至定价结果返回,端到端延迟 < 200ms。
- 连续学习: 模型可在线增量更新,适应概念漂移。
- 策略灵活: 支持按客户群、渠道、时段动态切换定价规则。
- 资源高效: 弹性伸缩,按需消费计算资源,避免批量高峰。
1.3 课程目标
本课程旨在培养具备金融业务理解 + 流式计算工程 + 模型部署三位一体能力的实战型架构师。完成学习后,学员应能:
- 设计基于 Spark Structured Streaming 的实时特征管道。
- 集成模型 Serving 框架(如 TensorFlow Serving / PMML / ONNX)实现毫秒级推理。
- 实现信用额度定价的流式决策闭环,包含策略编排、AB 测试与监控告警。
- 优化流式作业的吞吐、延迟与容错,满足金融级 SLA。
1.4 学习路径与课程地图
课程共 30 章,按知识递进关系分为五个模块:
| 模块 | 章节范围 | 核心内容 |
|---|---|---|
| 基础篇 | 第 1~6 章 | 业务背景、Spark 流式基础、特征工程、模型训练与导出 |
| 核心篇 | 第 7~15 章 | Structured Streaming 状态管理、模型 Serving 集成、实时定价策略引擎 |
| 进阶篇 | 第 16~22 章 | 延迟优化、容错与 Exactly-Once、AB 测试、监控告警 |
| 实战篇 | 第 23~27 章 | 端到端项目:实时额度定价系统搭建、压测与调优 |
| 扩展篇 | 第 28~30 章 | 联邦学习、边缘部署、行业趋势与最佳实践 |
学习建议: 本课程假设学员已具备 Scala/Python 基础与 Spark 基本概念。每章末尾提供可运行的代码示例与数据集,建议在本地或云环境搭建 Spark 3.x + Kafka 2.8+ 集群进行实操。