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

Flink CEP实时交易风控规则实战教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学与风控概述
实时交易风控的背景 · 常见欺诈场景 · Flink CEP在风控中的价值
课程导学风控概述
02
Flink基础回顾
Flink架构 · DataStream API · 时间语义
Flink基础回顾
03
CEP概念与核心原理
事件 · 模式 · 模式序列
CEP概念
04
Flink CEP开发环境搭建
Maven项目配置 · 依赖引入 · 本地运行模式与集群模式
FlinkCEP
05
简单模式定义与匹配
Pattern API入门 · 单例模式 · 循环模式
简单模式定义匹配
06
模式序列与组合
严格连续 · 宽松连续 · 非确定性宽松连续
模式序列组合
07
时间窗口与阈值控制
within子句 · 窗口长度 · 超时事件处理
时间窗口阈值控制
08
CEP结果输出与处理
PatternSelectFunct… · PatternFlatSelectF… · 侧输出流处理超时
CEP结果输出
09
风控规则引擎架构设计
规则引擎分层 · 规则存储 · 规则加载
风控规则引擎架构…规则引擎分层
10
规则模型抽象
规则POJO定义 · 条件表达式 · 动作配置
规则模型抽象POJO
11
动态规则加载与更新
从MySQL/Redis/Zooke… · 规则变更监听
动态规则加载更新
12
规则编译与模式构建
将JSON规则解析为Pattern对… · 条件表达式动态编译
规则编译模式构建
13
实时交易数据接入
Kafka Source配置 · 交易事件序列化与反序列化 · 事件时间戳提取
实时交易数据接入Kafka
14
交易事件模型定义
交易事件POJO · 事件类型枚举 · 金额
交易事件模型定义POJO
15
风控特征计算
滑动窗口聚合 · 用户历史行为统计 · 设备指纹
风控特征计算滑动窗口聚合
16
多规则并行匹配
CEP算子并行度设置 · KeyBy策略 · 规则分组与隔离
多规则并行匹配CEP
17
规则优先级与冲突处理
规则命中优先级排序 · 规则互斥逻辑 · 告警去重
规则优先级冲突处理
18
告警与处置动作
告警消息格式化 · 发送到Kafka/Webhook/短… · 风控处置指令下发
告警处置动作
19
实战案例一
登录风控——异地登录检测 · 暴力破解检测 · 异常时间登录
实战案例一登录风控
20
实战案例二
交易风控——大额交易 · 短时高频交易 · 跨设备交易
实战案例二交易风控
21
实战案例三
账户风控——注册异常 · 撞库攻击 · 批量注册
实战案例三账户风控
22
实战案例四
支付风控——同卡多设备 · 金额试探 · 盗刷检测
实战案例四支付风控
23
CEP性能优化
状态大小优化 · Checkpoint调优 · 算子链与资源分配
CEP性能优化
24
CEP与Flink SQL集成
使用SQL MATCH_RECOGN… · CEP与SQL对比
CEPFlink
25
规则测试与验证
单元测试 · 模拟数据流测试 · 规则覆盖率与回测
规则测试验证
26
监控与告警链路
Flink作业监控 · 规则命中率监控 · 延迟监控
监控告警链路
27
规则生命周期管理
规则上线 · 灰度 · 回滚
规则生命周期管理规则上线
28
高可用与容错
Exactly-Once语义 · 状态一致性 · 故障恢复
高可用容错
29
项目实战
从零搭建实时风控平台——需求分析 · 架构设计 · 模块实现
项目实战从零搭建实时风控…
30
课程总结与进阶方向
CEP局限性 · AI风控融合 · 未来趋势
课程总结进阶方向