VIP20
本课程属于：046-反欺诈图谱阈值分层试验 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink实时反欺诈图谱应用教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论与背景
实时反欺诈的行业痛点 · 图谱技术优势 · Flink在反欺诈中的核心价值
课程导论背景
02
知识图谱基础
实体 · 关系 · 属性的概念
知识图谱基础实体
03
Flink核心概念速览
DataStream · KeyedStream · Window
Flink核心概念速览
04
反欺诈图谱数据模型设计
用户 · 设备 · IP
反欺诈图谱数据模…用户
05
Flink环境搭建与项目初始化
Maven/Gradle项目结构 · Flink依赖配置 · 本地开发环境启动与调试
Flink环境搭建
06
数据源接入与预处理
Kafka作为事件源 · Flink Kafka Consum… · JSON/AVRO反序列化
数据源接入预处理
07
实时实体抽取与关系构建
从原始事件流中提取用户 · 设备 · IP等实体
实时实体抽取关系构建
08
Flink状态后端与图状态管理
使用ValueState/MapSt… · 使用ListState存储关系历史 · 状态TTL配置
Flink状态后端
09
基于CEP的时序关联规则
Flink CEP（Complex… · 检测短时间高频交易 · 异地登录等模式
CEP基于
10
图谱路径查询与风险传播
基于Flink Gelly或自实现B… · 在实时子图中查找可疑路径（如多级转账 · 设备共享）
图谱路径查询风险传播
11
实时特征工程
基于图谱结构特征（一度邻居数 · 二度连通性 · 设备聚集度）生成实时特征向量
实时特征工程基于图谱结构特征
12
规则引擎集成
将图谱特征与规则引擎（Drools/… · 实现动态规则匹配与风险评分
规则引擎集成Drools
13
机器学习模型推理
使用Flink的PMML/ONNX/… · 对图谱特征进行实时推理 · 输出欺诈概率
机器学习模型推理Flink
14
反欺诈图谱的存储与更新
将实时构建的图谱写入Neo4j/Ti… · 使用Flink sink批量更新节点…
反欺诈图谱的存储更新
15
实时告警与处置
基于风险评分触发告警 · 输出到Kafka/Elasticse… · 联动风控决策系统进行阻断或人工审核
实时告警处置
16
反欺诈图谱的冷启动与历史数据回填
使用Flink批处理模式从Hive/… · 构建初始图谱
反欺诈图谱的冷启…历史数据回填
17
图计算与社区发现
使用Flink Gelly实现Lou… · 实时发现欺诈团伙社区
图计算社区发现
18
时间窗口与滑动图分析
基于Flink滑动窗口 · 计算窗口内子图的密度 · 直径
时间窗口滑动图分析
19
反欺诈图谱的监控与运维
Flink作业Metrics监控 · 图谱数据质量监控 · 延迟与吞吐量调优
反欺诈图谱的监控运维
20
多源异构数据融合
将设备指纹 · 生物特征 · 第三方黑名单等外部数据融合进图谱
多源异构数据融合将设备指纹
21
实时图谱的版本管理与回溯
使用Flink状态快照与Savepo… · 实现图谱版本回滚与历史事件回溯分析
实时图谱的版本管…回溯
22
反欺诈图谱的隐私与安全
数据脱敏 · 差分隐私 · 联邦学习在反欺诈图谱中的应用
反欺诈图谱的隐私安全
23
Flink与图数据库的深度集成
使用Flink Neo4j Conn… · Gremlin查询优化 · 批量写入与事务控制
Flink图数据库的深度集…
24
反欺诈图谱的测试与验证
单元测试 · 集成测试 · 混沌工程
反欺诈图谱的测试验证
25
性能优化
Flink算子链优化 · KeyBy策略 · 序列化优化
性能优化Flink
26
反欺诈图谱的扩展性设计
水平扩展 · 分区策略 · 动态负载均衡
反欺诈图谱的扩展…水平扩展
27
实战案例一
实时信用卡盗刷检测 · 识别盗刷团伙
实战案例一实时信用卡盗刷检…
28
实战案例二
实时账户接管（ATO）检测 · IP · 行为序列的图谱异常检测
实战案例二ATO
29
实战案例三
实时电商刷单与虚假交易检测
实战案例三实时电商刷单
30
课程总结与未来展望
反欺诈图谱技术趋势 · Flink与AI结合 · 图神经网络（GNN）在反欺诈中的前沿…
课程总结未来展望