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

实时交易风控巡检：Flink CEP与告警阈值实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学
实时交易风控巡检的行业背景与痛点 · Flink CEP在风控中的核心价值
课程导学实时交易风控巡检…
02
环境准备
Flink集群搭建（Standalo… · Kafka消息队列安装与配置
环境准备Flink
03
数据模型设计
定义交易事件（Transaction… · 包含用户ID · 金额
数据模型设计Transaction
04
Flink基础回顾
DataStream API核心概念 · Source/Sink/Transf…
Flink基础回顾
05
CEP概念精讲
事件 · 模式 · 模式序列
CEP概念精讲
06
简单阈值告警
单事件规则——单笔交易金额超过100… · 使用Pattern.where()实…
简单阈值告警单事件规则
07
连续失败次数检测
定义“连续3次交易失败”模式 · 使用times()与consecut…
连续失败次数检测定义“连续3次交…
08
时间窗口内高频交易
5分钟内同一用户交易超过10笔 · 使用within()与times()…
时间窗口内高频交…5分钟内同一用户…
09
地理异常检测
同一用户短时间内（1分钟）在不同城市… · 使用followedBy()与whe…
地理异常检测同一用户短时间内
10
设备指纹突变
同一用户短时间内（2分钟）设备指纹发… · 使用next()严格连续模式
设备指纹突变同一用户短时间内
11
金额阶梯递增
同一用户连续3笔交易金额递增超过50… · 使用until()与迭代条件
金额阶梯递增同一用户连续3笔…
12
黑白名单过滤
结合BroadcastStream动… · 实时过滤并告警
黑白名单过滤BroadcastStr…
13
告警阈值动态配置
从外部配置中心（如Nacos/Red… · 更新Pattern条件
告警阈值动态配置Nacos/Red
14
复杂事件序列
定义“登录失败→小额试探→大额转账”… · 使用followedByAny()
复杂事件序列定义“登录失败→…
15
超时未完成事件
定义“发起交易后30秒内未收到确认”… · 使用within()与sideOut…
超时未完成事件定义“发起交易后…
16
CEP与状态后端集成
使用RocksDBStateBack… · 保障大状态下的稳定性
CEP状态后端集成
17
告警去重与聚合
同一规则在1分钟内重复触发时 · 合并为一条告警 · 使用自定义ProcessFuncti…
告警去重聚合
18
告警输出与通知
将告警结果写入Kafka · 并通过Webhook（钉钉/飞书）推…
告警输出通知
19
规则热更新
基于Flink Savepoint实… · 无需重启作业
规则热更新Flink
20
性能调优
CEP算子并行度设置 · 事件时间与处理时间选择 · 缓冲区大小优化
性能调优CEP
21
单元测试
使用Flink Test Harne… · 验证告警逻辑正确性
单元测试Flink
22
端到端集成测试
搭建Kafka+Flink+Redi…
端到端集成测试Kafka+Flink+…
23
监控与告警
使用Prometheus+Grafa… · 吞吐量 · CEP匹配率
监控告警
24
实战案例1
信用卡套现检测——多笔整数金额交易 · 短时间内跨商户消费
实战案例1信用卡套现检测
25
实战案例2
账户盗用检测——异地登录+密码修改+…
实战案例2账户盗用检测
26
实战案例3
洗钱行为检测——多层转账 · 金额接近阈值 · 时间间隔规律
实战案例3洗钱行为检测
27
实战案例4
薅羊毛检测——同一IP/设备短时间内…
实战案例4IP
28
常见问题与排错
CEP匹配不触发 · 状态膨胀 · 反压问题排查思路
常见问题排错
29
生产环境最佳实践
规则优先级管理 · 告警分级 · 降级与熔断策略
生产环境最佳实践规则优先级管理
30
课程总结与展望
Flink CEP未来演进方向（SQ… · AI辅助规则生成）
课程总结Flink