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

Flink反欺诈特征服务从入门到实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学与反欺诈概述
课程目标 · 学习路径 · 反欺诈业务场景（支付
课程导学反欺诈概述
02
Flink基础与环境搭建
Flink发展史 · 核心特性（事件驱动 · 流批一体）
Flink环境搭建
03
Flink DataStream API入门
DataStream编程模型 · Source/Sink概念 · WordCount实战
FlinkDataStream
04
Flink时间语义与Watermark
EventTime/Processi… · Watermark原理与生成策略 · Allowed Lateness与S…
FlinkWatermark
05
Flink状态管理与容错机制
Keyed State与Operat… · ValueState/ListSta… · Checkpoint与Savepoi…
Flink状态管理
06
Flink Window操作详解
Tumbling Window · Sliding Window · Session Window
FlinkWindow
07
Flink CEP复杂事件处理
CEP概念 · Pattern API（begin/… · CEP在反欺诈中的应用（如短时间高频…
FlinkCEP
08
反欺诈特征工程基础
特征分类（统计特征 · 序列特征 · 图谱特征）
反欺诈特征工程基…特征分类
09
实时特征计算架构设计
Lambda架构与Kappa架构对比 · 反欺诈特征服务整体架构（数据接入->… · 技术选型（Flink+Kafka+R…
实时特征计算架构…Lambda
10
数据接入层设计
Kafka Topic规划（事件To… · 特征结果Topic） · Avro/Protobuf序列化
数据接入层设计Kafka
11
Flink SQL在特征计算中的应用
Flink SQL环境搭建 · CREATE TABLE定义Kafk… · 窗口聚合计算特征（如SUM/COUN…
FlinkSQL
12
基于Flink的滑动窗口统计特征实战
计算用户过去5分钟/1小时/1天的交… · 金额总和 · 最大金额
Flink基于
13
基于Flink的序列特征实战
使用Flink CEP检测用户“登录… · 输出序列特征标签
Flink基于
14
基于Flink的比率与差值特征实战
计算当前交易金额与用户历史平均金额的… · 当前IP下设备数占比等 · 使用RichMapFunction与…
Flink基于
15
特征存储层设计
Redis数据结构选择（String… · 特征Key设计规范（user_id · TTL策略与内存优化
特征存储层设计Redis
16
特征服务API层设计
RESTful API设计（查询单个… · Spring Boot集成Redis… · API高并发优化（连接池/缓存/限流…
API特征服务
17
Flink与Redis维表关联实战
使用AsyncIO实现异步维表查询 · Flink SQL Temporal… · 性能调优（超时/容量）
FlinkRedis
18
反欺诈规则引擎集成
规则引擎（Drools/EasyRu… · 将实时特征输入规则引擎进行评分 · 规则动态更新方案（配置中心+广播流）
反欺诈规则引擎集…Drools/EasyR…
19
实时特征计算延迟优化
MiniBatch与BufferTi… · KeyBy优化（避免数据倾斜） · 序列化优化（Pojo vs Avro…
实时特征计算延迟…MiniBatch
20
Flink作业监控与告警
Flink Metrics（延迟/吞… · Prometheus+Grafana… · 作业失败自动重启策略与告警
Flink作业监控
21
多流Join在反欺诈中的应用
双流Join（交易流+设备流）计算设… · Interval Join与Regu… · 状态清理与TTL配置
Join多流
22
复杂特征
图谱特征计算 · 计算用户一度/二度关联关系 · 团伙检测（连通图）在反欺诈中的应用
复杂特征图谱特征计算
23
特征回溯与回填
离线特征计算（使用Flink Bat… · 特征回溯流程（指定时间范围重算） · 特征一致性校验（实时vs离线）
特征回溯回填
24
特征版本管理与AB测试
特征版本号设计 · AB测试分流方案（基于用户ID Ha… · Flink广播流下发实验配置
AB特征版本管理
25
Flink CDC同步特征元数据
Flink CDC监听MySQL B… · 实时同步特征配置表到Flink广播状… · 实现特征动态注册
FlinkCDC
26
全链路压测与性能评估
压测工具（JMeter/Locust… · 特征服务TPS/QPS评估 · Flink作业反压测试
全链路压测性能评估
27
生产环境部署与运维
Flink On YARN/K8s部… · 资源动态扩缩容 · 日志采集（ELK）
生产环境部署运维
28
实战项目一
支付反欺诈实时特征系统：需求分析 · 特征设计（交易频次/金额异常/设备指… · Flink作业开发
实战项目一支付反欺诈实时特…
29
实战项目二
信贷申请反欺诈特征系统 · 设备关联特征 · 社交网络特征
实战项目二信贷申请反欺诈特…
30
课程总结与进阶方向
反欺诈特征服务最佳实践总结 · Flink 2.0新特性展望 · 图计算（GraphScope）
课程总结进阶方向