VIP20
本课程属于：035-金融知识图谱批流一体链路 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

金融图谱Python批流一体链路案例集

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论与金融图谱概述
金融图谱的定义 · 应用场景（风控 · 反欺诈
课程导论金融图谱概述
02
Python环境与依赖安装
Python 3.10+环境配置 · 虚拟环境搭建 · 核心依赖（pandas
Python环境
03
批流一体核心概念
批处理与流处理的区别 · Lambda架构与Kappa架构 · Flink在金融图谱中的角色
批流一体核心概念批处理
04
金融数据模型设计
实体（客户 · 账户 · 交易）
金融数据模型设计实体
05
批量数据源接入
从CSV/Parquet文件批量读取… · 数据清洗与字段映射 · 数据质量校验
批量数据源接入CSV/Parquet
06
流式数据源接入
使用Kafka模拟实时交易流 · Kafka Producer/Con… · 消息序列化（JSON/Avro）
流式数据源接入Kafka
07
PyFlink批处理基础
Table API与DataStre… · 批处理环境搭建 · 读取静态数据集
PyFlink批处理基础
08
PyFlink流处理基础
流处理环境配置 · Kafka Source连接 · 事件时间与水位线设置
PyFlink流处理基础
09
金融实体识别与抽取
从交易日志中提取客户ID · 账户ID · 对手方信息
金融实体识别抽取
10
关系抽取与关联规则
转账关系 · 担保关系 · 持股关系的逻辑定义
关系抽取关联规则
11
图数据库Neo4j基础
Neo4j安装与配置 · Cypher查询语言入门 · 节点与关系创建
Neo4j图数据库
12
批量写入Neo4j
使用py2neo批量导入实体节点 · 使用LOAD CSV批量导入关系 · 事务控制
Neo4j批量写入
13
流式写入Neo4j
实时交易流写入Neo4j · 批量提交优化 · 避免重复关系
Neo4j流式写入
14
图特征工程
节点度 · PageRank · 社区发现（Louvain）
图特征工程节点度
15
批处理图计算
使用NetworkX进行离线图分析 · 计算全图统计指标 · 生成特征宽表
批处理图计算NetworkX
16
流式图计算
滑动窗口内的子图统计 · 实时PageRank近似计算 · Flink Gelly集成
流式图计算滑动窗口内的子图…
17
批流一体链路整合
批处理历史数据构建初始图谱 · 流处理实时增量更新 · 状态一致性保证
批流一体链路整合批处理历史数据构…
18
金融风险图谱构建
黑名单实体标记 · 异常交易模式（循环转账 · 快进快出）图谱规则
金融风险图谱构建黑名单实体标记
19
反欺诈实时检测
基于图谱的实时欺诈评分 · 可疑路径检测（2跳内关联） · 告警输出
反欺诈实时检测基于图谱的实时欺…
20
投研知识图谱
公司关联网络 · 产业链上下游关系 · 股东穿透分析
投研知识图谱公司关联网络
21
批流一体数据管道监控
Prometheus + Grafa… · Kafka Lag监控 · Neo4j写入延迟
批流一体数据管道…Prometheus
22
数据血缘与元数据管理
使用Atlas或自定义血缘追踪 · 批流作业元数据记录
数据血缘元数据管理
23
性能优化
Flink并行度调优 · Neo4j批量写入优化 · Kafka分区策略
性能优化Flink
24
容错与状态恢复
Flink Checkpoint与S… · Exactly-Once语义 · Neo4j事务回滚
容错状态恢复
25
金融图谱可视化
Neo4j Browser可视化 · PyVis交互式图展示 · Gephi导出
金融图谱可视化Neo4j
26
API服务层
使用FastAPI构建图谱查询接口 · 实时风险查询 · 批量特征服务
API服务层
27
案例实战一
信用卡反欺诈图谱
案例实战一信用卡反欺诈图谱
28
案例实战二
供应链金融图谱
案例实战二供应链金融图谱
29
案例实战三
反洗钱可疑交易图谱：多层转账追踪 · 团伙识别
案例实战三反洗钱可疑交易图…
30
课程总结与最佳实践
批流一体架构选型建议 · 生产环境注意事项 · 未来演进方向
课程总结最佳实践