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. 基础夯实(第1-5章): 金融图谱数据模型、Spark SQL核心算子、样本偏差理论。
  2. 校验实战(第6-15章): 分布对比、PSI计算、KS检验、卡方检验、图谱特征偏差诊断。
  3. 修复与优化(第16-25章): 重采样策略、分层抽样、偏差补偿、Spark性能调优。
  4. 工程落地(第26-30章): 自动化校验流水线、监控告警、案例复盘与最佳实践。
课程学习路径与知识体系 阶段一 基础夯实 第1-5章 图谱模型·SQL算子·偏差理论 阶段二 校验实战 第6-15章 PSI·KS·卡方·图谱特征诊断 阶段三 修复与优化 第16-25章 重采样·分层·补偿·性能调优 阶段四 工程落地 第26-30章 流水线·监控·复盘 关键交付物 • 样本偏差诊断报告模板(含PSI/KS/分布对比图表) • 基于Spark SQL的自动化校验脚本库(覆盖10+偏差检测场景) • 生产级偏差修复流水线架构设计与代码实现

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. 训练样本中“多头借贷”用户占比仅为全量的1/3(选择偏差)
  2. 标签定义仅覆盖逾期60天以上用户,忽略30-60天潜在风险(标签偏差)
  3. 2024年Q1样本中“担保网络”密度显著低于2023年同期(时间偏差)
  4. 高净值用户群体在样本中被系统性过滤(幸存者偏差)
课程承诺: 每一章的理论讲解后,都配有可直接运行的Spark SQL代码示例。你不需要从零搭建集群——课程提供Docker Compose一键启动的沙箱环境,5分钟内即可进入实战状态。