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

异常交易巡检指南：Flink CEP与告警阈值调优技巧

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
异常交易巡检的背景与挑战 · Flink CEP在风控中的核心价值 · 课程目标与学习路径
课程导论异常交易巡检的背…
02
Flink基础回顾
Flink架构概览 · DataStream API核心概念 · 时间语义与Watermark机制
Flink基础回顾
03
CEP概念精讲
什么是复杂事件处理 · CEP的核心术语（事件 · 模式
CEP概念精讲
04
Flink CEP快速入门
环境搭建 · 第一个CEP程序（简单序列匹配） · 代码结构与运行流程
FlinkCEP
05
模式API详解（上）
Pattern对象的创建 · 单例模式与循环模式 · 量词（times
API模式
06
模式API详解（中）
条件限定（where · or · until）
API模式
07
模式API详解（下）
模式序列的连续性策略（严格连续 · 宽松连续 · 非确定宽松连续）
API模式
08
事件选择与跳过策略
afterMatchSkipStra… · SKIP_PAST_LAST_EVE… · SKIP_TO_FIRST
事件选择跳过策略
09
CEP时间约束
within子句的使用 · 窗口长度对匹配的影响 · 超时事件的处理与侧输出流
CEP时间约束
10
CEP状态管理与容错
CEP算子的状态存储 · Checkpoint与Savepoi… · Exactly-Once语义保障
CEP状态管理
11
异常交易场景建模（一）
高频交易检测——短时间内大量交易（刷… · 抢购）的模式定义与实现
异常交易场景建模高频交易检测
12
异常交易场景建模（二）
小额试探后大额盗刷——“踩点”模式的…
异常交易场景建模小额试探后大额盗…
13
异常交易场景建模（三）
跨设备/跨IP登录后的异常转账——地…
异常交易场景建模IP
14
异常交易场景建模（四）
循环转账洗钱——闭环检测（A->B-…
异常交易场景建模A
15
告警阈值调优基础
阈值的定义与分类（静态阈值 · 动态阈值 · 滑动窗口阈值）
告警阈值调优基础阈值的定义
16
基于统计的阈值设定
均值 · 标准差 · 百分位数法在交易金额/频率阈值中的应…
基于统计的阈值设…均值
17
基于机器学习的动态阈值
使用在线学习算法（如EWMA · Holt-Winters）自适应调整…
基于机器学习的动…EWMA
18
阈值调优实战
Flink CEP中集成实时统计函数… · ProcessFunction）动态…
阈值调优实战Flink
19
告警降噪与聚合
重复告警抑制 · 告警聚合（相同规则 · 相同用户）
告警降噪聚合
20
告警输出与通知
自定义告警Sink（Kafka · Elasticsearch · Webhook）
告警输出通知
21
性能调优（一）
CEP算子并行度设置 · KeyBy策略优化 · 避免数据倾斜
性能调优CEP
22
性能调优（二）
模式匹配的剪枝优化 · 使用NFA优化 · 减少回溯
性能调优模式匹配的剪枝优…
23
性能调优（三）
状态大小控制 · TTL配置 · RocksDB状态后端调优
性能调优状态大小控制
24
测试与验证
单元测试CEP模式（使用Flink… · 回测历史数据验证规则有效性
测试验证
25
监控与运维
Flink作业监控指标（延迟 · 吞吐量 · 匹配率）
监控运维
26
案例实战（一）
银行转账异常检测系统——从需求分析到…
案例实战银行转账异常检测…
27
案例实战（二）
电商支付风控——结合CEP与规则引擎…
案例实战CEP
28
案例实战（三）
证券交易市场操纵检测——大单拆分 · 对倒交易的CEP识别
案例实战证券交易市场操纵…
29
进阶话题
CEP与Flink SQL的结合 · CEP on Event Time… · CEP的未来演进
进阶话题CEP
30
课程总结与最佳实践
常见陷阱与避坑指南 · 生产环境部署Checklist · 推荐学习资源与社区
课程总结最佳实践