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

Flink CEP实战：实时风控稳定性巡检与PSI监控

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学与背景
实时风控与稳定性巡检的行业痛点 · PSI（Population Sta… · Flink CEP为何成为首选技术栈
课程导学背景
02
Flink基础回顾
Flink架构 · DataStream API核心概念 · 时间语义（Event Time /…
Flink基础回顾
03
CEP概念与原理
什么是复杂事件处理（CEP） · CEP与普通流处理的区别 · Flink CEP的核心组件（Pat…
CEP概念
04
Flink CEP快速入门
环境搭建（Maven依赖 · Flink版本选择） · 第一个CEP Demo（检测连续登录…
FlinkCEP
05
CEP Pattern API详解（上）
Pattern定义 · begin/where/or/not… · 量词（oneOrMore
CEPPattern
06
CEP Pattern API详解（下）
within时间约束 · until终止条件 · consecutive连续匹配
CEPPattern
07
CEP事件选择与处理
select与flatSelect的… · OutputTag与侧输出流处理超时… · PatternTimeoutFunc…
CEP事件选择
08
CEP状态管理与容错
Flink Checkpoint与S… · Pattern状态大小优化 · Exactly-Once语义保证
CEP状态管理
09
实时风控场景建模
风控规则引擎架构 · 规则动态加载与热更新 · 基于CEP的规则模板设计（阈值规则
实时风控场景建模风控规则引擎架构
10
PSI指标深度解析
PSI计算公式推导 · PSI在特征分布漂移检测中的应用 · PSI阈值设定（0.1/0.2/0.…
PSI指标深度解析
11
实时PSI计算方案设计
离线PSI vs 实时PSI · 滑动窗口分桶策略 · 等频分桶与等距分桶选择
PSI实时
12
Flink实现实时PSI计算（上）
自定义AggregateFuncti… · 使用MapState维护历史分布 · 窗口触发时机设计
FlinkPSI
13
Flink实现实时PSI计算（下）
实时PSI计算完整代码实现 · 性能优化（预聚合 · 增量计算）
FlinkPSI
14
稳定性巡检指标体系
巡检指标分类（可用性 · 延迟 · 吞吐量
稳定性巡检指标体…巡检指标分类
15
基于CEP的异常巡检模式设计
突增/突降检测（绝对值阈值+百分比阈… · 周期性波动检测（同比/环比） · 多指标联合告警（AND/OR逻辑）
CEP基于
16
实时巡检引擎架构
数据采集层（Kafka/Pulsar… · 计算层（Flink CEP） · 告警层（Webhook/短信/钉钉）
实时巡检引擎架构Kafka/Pulsar
17
CEP模式库与规则管理
规则配置中心设计（MySQL/APO… · 规则版本控制 · 规则生效时间窗口
CEP模式库
18
动态规则热更新实战
基于BroadcastStream的… · Pattern动态构建 · 规则变更时的状态清理与迁移
动态规则热更新实…BroadcastStr…
19
多流关联与复杂场景
使用CEP的followedBy与n… · 双流Join与CEP的对比 · 基于IntervalJoin的补充方…
多流关联复杂场景
20
超时与未匹配事件处理
PatternTimeoutFunc… · 侧输出流收集超时事件 · 超时事件重入规则队列策略
超时未匹配事件处理
21
CEP性能调优（上）
并行度设置与KeyBy优化 · Pattern的共享与复用 · 避免状态膨胀（使用MapState代…
CEP性能调优
22
CEP性能调优（下）
Flink内存调优（Managed… · Checkpoint间隔与超时设置 · 反压监控与定位
CEP性能调优
23
PSI监控告警实战
实时PSI计算任务部署 · PSI阈值告警规则配置 · 告警降噪（告警聚合/抑制/静默）
PSI监控告警实战
24
稳定性巡检大盘可视化
Grafana仪表盘设计（实时PSI… · 巡检指标热力图 · 告警事件时间线）
稳定性巡检大盘可…Grafana
25
案例实战一
交易风控反欺诈——基于CEP检测盗刷… · 实时PSI监控交易特征分布
案例实战一CEP
26
案例实战二
信贷风控模型监控——实时PSI监控模… · 结合CEP检测模型效果衰减（KS指标…
案例实战二PSI
27
案例实战三
系统稳定性巡检——黄金信号CEP巡检… · P99延迟突增 · 错误率飙升）
案例实战三CEP
28
生产环境部署与运维
Flink on YARN/K8s部… · 日志采集与链路追踪（SLS/Open… · CEP任务监控与自愈
生产环境部署运维
29
Flink CEP 2.0新特性与展望
Flink 1.18+ CEP改进 · SQL CEP（MATCH_RECO… · AI+CEP趋势
FlinkCEP
30
课程总结与面试指南
核心知识点回顾 · 常见面试题解析（CEP状态大小 · PSI计算精度
课程总结面试指南