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

Flink CEP风控巡检：异常交易实时监控教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
Flink CEP在风控领域的价值 · 异常交易实时监控的行业痛点 · 课程整体大纲与学习目标
课程导论Flink
02
Flink基础回顾
Flink架构 · DataStream API核心概念 · 时间语义与水位线（Watermark…
Flink基础回顾
03
CEP概念入门
什么是复杂事件处理（CEP） · CEP与普通流处理的区别 · Flink CEP的核心组件
CEP概念入门
04
Flink CEP环境搭建
Flink集群部署模式 · 开发环境（Maven/Gradle）… · 第一个CEP程序Hello Worl…
FlinkCEP
05
Pattern API详解（上）
Pattern定义 · 个体模式（Single Patter… · 组合模式（Combining Pat…
PatternAPI
06
Pattern API详解（中）
条件模式（where/or/unti… · 量词（times/oneOrMore… · 模式组（Group Pattern）
PatternAPI
07
Pattern API详解（下）
模式跳过策略（After Match… · 可选模式（optional） · 模式超时处理
PatternAPI
08
事件选择与提取
Event Selection · SelectFunction与Pat… · FlatSelectFunction…
事件选择提取
09
CEP时间语义
事件时间与处理时间在CEP中的差异 · 水位线对模式匹配的影响 · 迟到事件处理策略
CEP时间语义
10
CEP状态管理
CEP内部状态存储机制 · 状态后端配置（RocksDB/FS） · 状态TTL与清理策略
CEP状态管理
11
风控场景建模（一）
高频交易检测——定义短时间窗口内多次…
风控场景建模高频交易检测
12
风控场景建模（二）
跨账户关联交易——检测同一IP/设备…
风控场景建模IP
13
风控场景建模（三）
金额异常波动——基于阈值与滑动窗口的…
风控场景建模金额异常波动
14
风控场景建模（四）
登录失败连锁反应——连续失败后成功登…
风控场景建模登录失败连锁反应
15
风控场景建模（五）
地理异常穿越——短时间内异地登录与交…
风控场景建模地理异常穿越
16
动态规则与规则热更新
从外部配置中心（Nacos/Redi… · 规则变更对运行中作业的影响
动态规则规则热更新
17
CEP与外部系统集成
将告警结果输出到Kafka/Elas… · 通过Webhook触发实时风控响应
CEP外部系统集成
18
CEP性能优化（上）
并行度调优 · KeyBy策略选择 · 避免数据倾斜
CEP性能优化
19
CEP性能优化（下）
模式匹配的NFA优化 · 状态大小控制 · Checkpoint与容错配置
CEP性能优化
20
CEP测试与调试
单元测试CEP逻辑 · 使用Flink MiniCluste… · 日志与指标监控
CEP测试
21
实战项目（一）
信用卡盗刷实时检测系统——需求分析 · 数据模型设计 · Pattern定义
实战项目信用卡盗刷实时检…
22
实战项目（二）
信用卡盗刷实时检测系统——代码实现与…
实战项目信用卡盗刷实时检…
23
实战项目（三）
信用卡盗刷实时检测系统——结果可视化…
实战项目信用卡盗刷实时检…
24
实战项目（四）
内部员工异常操作审计——基于角色与操…
实战项目内部员工异常操作…
25
实战项目（五）
内部员工异常操作审计——结合用户画像…
实战项目内部员工异常操作…
26
Flink CEP与机器学习融合
使用CEP触发在线模型推理 · 模型特征实时计算与Pattern结合
FlinkCEP
27
多流关联CEP
使用connect/union合并多… · 跨流模式匹配（如交易流与风控规则流）
CEP多流关联
28
Flink CEP 2.0新特性
新Pattern API变更 · SQL中MATCH_RECOGNIZ…
FlinkCEP
29
生产环境最佳实践
作业参数调优清单 · 常见坑点与解决方案 · 监控告警体系搭建
生产环境最佳实践作业参数调优清单
30
课程总结与展望
Flink CEP在实时风控中的未来… · 推荐学习路径与进阶资源
课程总结Flink