风险传导图谱批流一体资料 - 第1节

1.1 风险传导图谱的定义

风险传导图谱（Risk Propagation Graph）是一种基于图结构的知识表示方法，用于描述金融风险事件在实体网络中的传播路径、影响范围与衰减规律。它将风险因子、业务节点、传导关系抽象为“节点-边”模型，使原本隐藏在业务流程与数据孤岛中的风险链条变得可计算、可追溯。

核心要素

1.2 批流一体技术背景

传统风险传导计算面临“批处理延迟高、流处理状态弱”的两难困境。批处理（如T+1跑批）无法捕捉日内风险突变；流处理（如实时规则引擎）又难以完成全图遍历、多跳传导等复杂计算。批流一体架构应运而生，它统一了离线批量与实时流式两种计算模式，让风险传导图谱既能做全量历史回溯，又能做毫秒级增量更新。

批流一体 vs 传统架构

1.3 课程目标与学习路径

课程目标

• 理解图谱建模：掌握风险传导图谱的图数据模型、传导规则定义与动态更新机制。
• 掌握批流一体工程：能够使用 Flink + Hudi 搭建支持全量回溯与实时更新的风险传导计算管道。
• 实战图谱应用：完成从数据接入、图谱构建、传导计算到可视化展示的完整闭环。
• 应对生产挑战：解决数据倾斜、状态膨胀、时序对齐等真实场景中的性能与一致性问题。

学习路径

1. 基础篇（第1-5章）：风险传导图谱概念、图数据库选型、Flink 批流一体基础、Hudi 存储原理。
2. 建模篇（第6-12章）：图谱 Schema 设计、传导规则引擎、动态节点与边的增量更新策略。
3. 计算篇（第13-20章）：全量图遍历、增量传导计算、多源风险叠加、时序对齐与回溯。
4. 工程篇（第21-26章）：性能调优、数据质量监控、容错与恢复、生产部署。
5. 实战篇（第27-30章）：企业担保圈风险传导、跨市场风险传染、实时预警大屏。

1.4 风险传导图谱批流一体架构总览

下图展示了本课程将要实现的整体架构，从数据源接入到图谱服务输出的完整链路：

1.5 本章小结

本章建立了风险传导图谱批流一体实战课程的知识地基。你已理解：

• 风险传导图谱是描述风险在金融网络中传播路径的图模型，核心要素包括节点、边、属性与规则。
• 批流一体架构解决了传统批处理延迟高与流处理状态弱的矛盾，Flink + Hudi 是当前主流技术栈。
• 课程按“基础→建模→计算→工程→实战”五阶段递进，每章均配有可运行代码与数据集。