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

Flink CEP风控巡检案例：异常交易与告警阈值优化

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
Flink CEP在风控领域的价值 · 异常交易场景概述 · 告警阈值优化的必要性
课程导论Flink
02
Flink基础回顾
Flink架构 · DataStream API · 时间语义
Flink基础回顾
03
CEP概念精讲
事件 · 模式 · 模式序列
CEP概念精讲
04
Flink CEP核心API
Pattern API详解 · select与flatSelect · PatternStream
FlinkCEP
05
环境搭建与数据源
Flink本地开发环境配置 · Kafka数据源接入 · 模拟交易数据生成
环境搭建数据源
06
简单异常检测
单事件模式匹配——检测单笔大额交易（…
简单异常检测单事件模式匹配
07
时序异常检测
严格连续模式——检测短时间内连续高频…
时序异常检测严格连续模式
08
组合异常检测
宽松连续模式——检测跨账户的关联转账…
组合异常检测宽松连续模式
09
循环模式与量词
使用times · oneOrMore · optional定义重复事件模式
循环模式量词
10
条件模式与迭代条件
基于事件属性的动态条件 · 迭代条件实现累计金额监控
条件模式迭代条件
11
时间窗口与CEP结合
在滑动窗口内进行模式匹配 · 检测窗口内异常聚合
CEP时间窗口
12
告警阈值静态配置
基于固定阈值的告警规则实现（如单笔>…
告警阈值静态配置基于固定阈值的告…
13
告警阈值动态配置
从外部配置中心（如Nacos/Red…
告警阈值动态配置Nacos/Red
14
阈值优化基础
基于统计学的阈值设定方法（均值 · 标准差 · 百分位数）
阈值优化基础基于统计学的阈值…
15
阈值优化进阶
基于滑动窗口的动态阈值计算（实时计算…
阈值优化进阶基于滑动窗口的动…
16
阈值优化高级
基于机器学习（孤立森林）的异常分数与…
阈值优化高级基于机器学习
17
多维度告警聚合
按用户ID · 设备ID · IP地址聚合告警
多维度告警聚合ID
18
告警降噪与分级
告警严重级别划分（低 · 中 · 高
告警降噪分级
19
状态管理与容错
Flink Checkpoint与S…
状态管理容错
20
CEP性能调优
并行度设置 · 状态后端选择（RocksDB） · 模式匹配优化
CEP性能调优
21
复杂事件序列超时处理
within子句与超时事件的处理逻辑
复杂事件序列超时…within
22
CEP与侧输出流
将超时事件 · 未匹配事件分流到侧输出流进行二次分析
CEP侧输出流
23
实时风控巡检看板
使用Flink SQL + Elas…
实时风控巡检看板Flink
24
告警通知集成
对接钉钉 · 企业微信 · 邮件等渠道发送实时告警
告警通知集成对接钉钉
25
案例实战一
信用卡盗刷检测——检测短时间内异地多…
案例实战一信用卡盗刷检测
26
案例实战二
洗钱交易检测——检测多层转账循环（A…
案例实战二洗钱交易检测
27
案例实战三
账户登录异常检测——检测暴力破解（多…
案例实战三账户登录异常检测
28
案例实战四
优惠券薅羊毛检测——检测同一设备/I…
案例实战四优惠券薅羊毛检测
29
阈值优化效果评估
准确率 · 召回率 · F1-score
阈值优化效果评估准确率
30
课程总结与展望
Flink CEP未来趋势 · 与AI大模型结合的风控新范式
课程总结Flink