VIP20

本课程属于：002-反欺诈图谱变量衍生与分箱 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

反欺诈Flink CEP变量衍生分箱实操案例

共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

反欺诈场景概述与业务挑战

常见欺诈类型 · 实时风控需求 · CEP在反欺诈中的价值

反欺诈场景概述业务挑战

实时风控系统架构演进

从批处理到流处理 · Lambda架构与Kappa架构对比 · Flink在风控中的定位

实时风控系统架构…从批处理到流处理

Flink基础与环境搭建

Flink发展史 · 安装部署 · 集群模式

Flink环境搭建

CEP核心概念

事件 · 流 · 模式

CEP核心概念

Flink CEP API详解

Pattern API基础 · 个体模式 · 组合模式

CEP规则定义实战

基于信用卡盗刷场景的规则编写 · 近邻时间约束 · 量词使用

CEP规则定义实战

变量衍生概念与意义

为什么需要变量衍生？常见衍生方式（聚… · 窗口 · 比率

变量衍生概念意义

Flink中的变量衍生实现

使用ProcessFunction · 自定义UDAF · 窗口聚合函数生成特征

Flink变量衍生实现

时间窗口衍生变量

滑动窗口 · 滚动窗口 · 会话窗口

时间窗口衍生变量滑动窗口

复杂事件序列衍生变量

连续事件之间的时间差 · 次数差 · 金额比等特征提取

复杂事件序列衍生…连续事件之间的时…

分箱（Binning）原理与类型

等距分箱 · 等频分箱 · 自定义分箱

Flink中实现等距分箱

使用UDF或SQL CASE WHE…

Flink实现等距分箱

Flink中实现等频分箱

实时分位数计算 · 近似分位数（TDigest）应用

Flink实现等频分箱

自定义分箱策略

基于业务知识的分箱（如金额区间 · 地域分组） · 动态分箱与静态分箱

自定义分箱策略基于业务知识的分…

变量衍生与分箱的联合处理

在Flink CEP规则中直接使用衍…

变量衍生分箱的联合处理

登录异常检测——基于IP · 设备 · 时间窗口的变量衍生与分箱

交易反欺诈——金额序列模式 · 频繁小额+大额等CEP规则+衍生特征

案例二交易反欺诈

账户盗用检测——多因素认证失败次数 · 地理位置突变 · 时间窗口聚簇

案例三账户盗用检测

Flink CEP状态管理

Checkerpoint · 状态后端 · 算子状态与Keyed State在规…

规则动态更新与热加载

使用广播流 · 配置中心联动 · 规则版本管理

规则动态更新热加载

并行度调优 · 事件时间偏移 · 状态TTL设置

性能优化并行度调优

基于Flink SQL的CEP替代方案

MATCH_RECOGNIZE语法 · 与Pattern API对比

变量与分箱的特征存储

Flink写入Redis/MySQL… · 特征回填与在线服务调用

变量分箱的特征存储

实时特征评估与模型集成

将衍生分箱后的特征送入规则引擎或轻量… · GBDT）

实时特征评估模型集成

搭建一个完整的实时反欺诈Demo——… · Flink CEP规则 · 变量衍生

实战项目Demo

项目架构与代码结构

Maven项目 · 模块划分 · 日志与监控接入

项目架构代码结构

多规则协同与优先级

规则优先级定义 · 冲突处理 · 降级与熔断机制

多规则协同优先级

测试与验证

单元测试 · 模拟数据生成 · 回溯测试（Replay）

线上部署与运维

Flink On YARN/K8s · 资源管理 · 告警与容错

线上部署运维

总结与进阶展望

CEP与Flink ML结合 · 图计算在反欺诈中的应用 · 未来趋势

进阶展望CEP