VIP20
本课程属于：003-实时交易风控训练集切分 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

异常交易样本构建与Flink实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
异常交易检测的业务价值 · 课程目标与学习路径 · Flink在风控领域的优势
课程导论异常交易检测的业…
02
异常交易基础概念
什么是异常交易 · 常见异常类型（盗刷 · 洗钱
异常交易基础概念什么是异常交易
03
交易数据模型设计
原始交易日志字段定义 · 用户画像与设备指纹 · 标签体系设计（正常/异常）
交易数据模型设计原始交易日志字段…
04
样本构建方法论
样本构建的流程（数据采集→清洗→特征… · 时间窗口与回溯机制
样本构建方法论样本构建的流程
05
Flink环境搭建
Flink集群安装与配置 · Flink SQL Client与D… · 本地开发环境准备
Flink环境搭建
06
Flink DataStream基础
Source/Sink/Transf… · KeyBy与Window · 状态编程入门
FlinkDataStream
07
Flink SQL基础
Table & SQL环境 · CREATE TABLE语句 · SELECT/WHERE/GROUP…
FlinkSQL
08
实时数据接入
Kafka Source连接器配置 · JSON格式解析 · 水位线与乱序处理
实时数据接入Kafka
09
数据清洗与预处理
字段过滤 · 空值填充 · 类型转换
数据清洗预处理
10
特征工程概述
统计特征（均值 · 方差 · 计数）
特征工程概述统计特征
11
Flink实时特征计算
使用滚动窗口计算交易频次 · 使用滑动窗口计算金额均值 · 使用Over窗口计算累计值
Flink实时特征计算
12
用户画像特征
历史交易偏好 · 设备指纹聚合 · 地理位置频繁度
用户画像特征历史交易偏好
13
序列模式特征
交易时间间隔 · 商户切换频率 · 金额突变检测
序列模式特征交易时间间隔
14
规则引擎样本标注
基于专家规则（单笔超限 · 短时多笔 · 异地登录）生成标签
规则引擎样本标注基于专家规则
15
机器学习样本标注
使用Flink ML进行离群点检测 · 孤立森林实时打分 · 阈值设定
机器学习样本标注Flink
16
样本存储设计
HBase表结构设计 · ClickHouse宽表设计 · Parquet文件格式选择
样本存储设计HBase
17
Flink Sink实战
写入HBase · 写入ClickHouse · 写入Kafka（作为下游样本流）
FlinkSink
18
样本质量评估
正负样本比例统计 · 特征分布可视化 · 回测准确率与召回率
样本质量评估正负样本比例统计
19
样本版本管理
样本快照机制 · 时间戳分区 · 版本回滚策略
样本版本管理样本快照机制
20
实时样本管道架构
整体数据流图（Kafka→Flink… · 容错与Exactly-Once语义
实时样本管道架构Kafka
21
Flink状态后端与Checkpoint
RocksDB状态后端配置 · Checkpoint策略 · 故障恢复测试
FlinkCheckpoint
22
性能优化
并行度调优 · 算子链与资源隔离 · 背压监控与处理
性能优化并行度调优
23
实战案例一
盗刷场景样本构建——规则+特征+实时…
实战案例一盗刷场景样本构建
24
实战案例二
洗钱场景样本构建——复杂网络特征+图…
实战案例二洗钱场景样本构建
25
实战案例三
薅羊毛场景样本构建——设备指纹+频次…
实战案例三薅羊毛场景样本构…
26
Flink与离线样本融合
批流一体架构 · Hive表与Flink表关联 · 历史样本回填
Flink离线样本融合
27
监控与告警
样本产出延迟监控 · 特征漂移检测 · 数据质量看板
监控告警
28
测试与部署
单元测试（Flink Test Ha… · CI/CD流水线 · 灰度发布策略
测试部署
29
课程总结
核心知识点回顾 · 常见踩坑经验 · 进阶学习路径
课程总结核心知识点回顾
30
附录
Flink SQL常用函数速查表 · 异常交易样本字段字典 · 推荐阅读资料
附录Flink