1. 课程导论:金融图谱与样本偏差概述
1.1 金融图谱:从数据到风控决策的基石
在金融风控领域,数据不再是孤立的字段,而是通过实体与关系编织成的知识网络。金融图谱(Financial Knowledge Graph)正是这一思想的工程化实现——它将用户、账户、交易、设备、联系人等实体抽象为节点,将转账、登录、担保、通话等行为抽象为边,构建出一个可计算、可推理的关联网络。
然而,图谱的构建与使用面临一个核心挑战:样本偏差。当用于训练风控模型的样本无法真实反映全量图谱分布时,模型在线上环境中的表现会急剧下降,甚至产生严重的误判风险。
核心认知: 金融图谱的样本偏差不是统计学上的“小问题”,而是直接导致风控模型失效、坏账率上升、合规风险加剧的工程隐患。本课程将围绕Spark SQL这一大数据引擎,系统性地解决这一难题。
1.2 样本偏差:金融风控的“隐形杀手”
样本偏差在金融图谱场景下主要表现为以下四种形态:
| 偏差类型 | 定义 | 金融图谱典型场景 | 后果 |
|---|---|---|---|
| 选择偏差 | 样本非随机选取,部分群体被系统性排除 | 仅用有贷后表现的用户建模,忽略未授信用户 | 模型对长尾客群失效 |
| 幸存者偏差 | 仅观察“存活”样本,忽略已流失或违约样本 | 只分析当前活跃账户,忽略已销户或逾期账户 | 高估用户质量 |
| 标签偏差 | 标签定义与真实风险不一致 | 逾期30天定义为“坏”,但实际坏账在90天后才暴露 | 模型学习到错误信号 |
| 时间偏差 | 训练集与测试集的时间窗口不匹配 | 用2023年数据训练,预测2024年政策变化后的行为 | 模型时效性差 |
实战警示: 在一次对公信贷图谱项目中,由于忽略了“担保关系”在样本中的稀疏性,导致模型对担保链下游企业的违约预测准确率从82%骤降至47%。样本偏差校验不是“锦上添花”,而是“生死攸关”。
1.3 课程目标与学习路径
本课程旨在培养学员掌握以下核心能力:
- 诊断能力: 使用Spark SQL对金融图谱数据进行全量/抽样分布对比,快速定位偏差来源。
- 校验能力: 构建PSI(群体稳定性指标)、KS统计量、分布距离等量化指标,形成自动化校验流水线。
- 修复能力: 基于校验结果,运用重采样、分层抽样、逆概率加权等策略修正样本分布。
- 工程能力: 在Spark集群上实现TB级图谱数据的偏差校验与修复,保障生产环境稳定运行。
学习路径分为四个阶段:
- 基础夯实(第1-5章): 金融图谱数据模型、Spark SQL核心算子、样本偏差理论。
- 校验实战(第6-15章): 分布对比、PSI计算、KS检验、卡方检验、图谱特征偏差诊断。
- 修复与优化(第16-25章): 重采样策略、分层抽样、偏差补偿、Spark性能调优。
- 工程落地(第26-30章): 自动化校验流水线、监控告警、案例复盘与最佳实践。
1.4 前置知识要求
为保障课程学习效果,学员需具备以下基础能力:
| 知识领域 | 具体要求 | 推荐学习资源 |
|---|---|---|
| SQL基础 | 熟练使用SELECT、JOIN、GROUP BY、窗口函数 | 《SQL必知必会》第1-12章 |
| Spark基础 | 理解RDD/DataFrame概念,能提交Spark作业 | Spark官方Quick Start + 《Spark权威指南》第1-4章 |
| 统计学基础 | 掌握均值/方差/分布/假设检验基本概念 | 《统计学》第3-7章(描述统计与推断统计) |
| 金融风控常识 | 了解逾期、违约、授信、贷后管理等术语 | 《风控要略》第1-3章 |
| Python/Java基础 | 能阅读和修改Spark SQL代码片段 | Python基础语法 + Spark DataFrame API文档 |
学习建议: 如果对Spark SQL的窗口函数或图谱的邻接表模型不熟悉,建议在开课前花2-3天完成前置知识补强。课程第2章会提供一次快速热身,但不会从头讲解SQL语法。
1.5 课程实战环境与数据说明
本课程所有实战案例均基于以下环境:
- 计算引擎: Apache Spark 3.4+(Spark SQL + DataFrame API)
- 数据规模: 模拟金融图谱数据集,包含1000万用户节点、5000万交易边、200万设备关联边
- 存储格式: Parquet + Delta Lake(支持ACID事务与时间旅行)
- 调度平台: YARN / Kubernetes(课程提供本地模式备选方案)
课程配套数据集已预先注入以下偏差场景,供学员在校验实战中逐一攻克:
- 训练样本中“多头借贷”用户占比仅为全量的1/3(选择偏差)
- 标签定义仅覆盖逾期60天以上用户,忽略30-60天潜在风险(标签偏差)
- 2024年Q1样本中“担保网络”密度显著低于2023年同期(时间偏差)
- 高净值用户群体在样本中被系统性过滤(幸存者偏差)
课程承诺: 每一章的理论讲解后,都配有可直接运行的Spark SQL代码示例。你不需要从零搭建集群——课程提供Docker Compose一键启动的沙箱环境,5分钟内即可进入实战状态。