VIP20

本课程属于：003-实时交易风控训练集切分 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

Flink CEP实时风控样本设计实战

共计 30 章节

点击此处阅读海量试读课程：100+行业、1000+细分领域

课程导论与风控背景

实时风控的行业痛点 · Flink CEP在风控中的定位 · 课程整体架构与学习目标

课程导论风控背景

Flink基础回顾

Flink架构 · DataStream API · 时间语义

Flink基础回顾

CEP概念与核心原理

事件 · 模式 · 模式序列

Flink CEP开发环境搭建

Maven/Gradle依赖 · 本地运行模式 · 集群提交模式

简单模式定义与匹配

单事件模式 · 量词（times/or/more） · 条件（where/subtype）

简单模式定义匹配

组合模式与序列

严格连续 · 松散连续 · 非确定性松散连续

组合模式序列

时间窗口与循环模式

within时间约束 · 循环模式（loop） · 滑动窗口匹配

时间窗口循环模式

模式组与子模式

模式组定义 · 子模式复用 · 复杂业务场景拆分

模式组子模式

CEP结果输出与侧输出

PatternSelectFunct… · PatternFlatSelectF… · 侧输出流（Side Output）处…

CEP结果输出

CEP与状态管理

CEP内部状态存储 · 状态TTL · Checkpoint对CEP的影响

CEP状态管理

CEP与定时器

内部定时器机制 · 超时事件处理 · 自定义定时器与CEP结合

CEP与ProcessFunction结合

灵活使用ProcessFunctio… · CEP与KeyedProcessFu… · 复杂业务逻辑实现

CEPProcessFunct…

风控样本定义与标签体系

样本正负定义 · 标签设计原则 · 样本时间窗口

风控样本定义标签体系

样本生成策略

基于规则匹配的样本生成 · 基于时间滑窗的样本生成 · 基于状态累积的样本生成

样本生成策略基于规则匹配的样…

样本数据源接入

Kafka数据源 · 自定义Source · 事件时间对齐

样本数据源接入Kafka

样本特征提取

CEP匹配结果特征化 · 上下文特征 · 聚合特征

样本特征提取CEP

样本存储与回放

样本写入HBase/ClickHou… · 样本回放机制 · 离线评估与在线验证

样本存储回放

CEP模式动态更新

动态模式加载 · 规则热更新 · 模式版本管理

CEP模式动态更新

CEP性能优化

并行度调优 · 状态大小控制 · 数据倾斜处理

CEP性能优化

CEP与机器学习结合

规则引擎+ML模型 · CEP输出作为ML特征 · 实时模型推理

CEP机器学习结合

多流关联与CEP

多流Join · Connect与CEP结合 · 示例：跨系统交易一致性检测

CEP多流关联

CEP与复杂事件分层

事件分层架构 · 原子事件 · 复合事件

CEP复杂事件分层

CEP测试与调试

单元测试（PatternTest） · 集成测试 · 日志与Metrics监控

CEP与Flink SQL结合

SQL定义模式 · SQL与CEP API对比 · 混合使用场景

实时风控样本管道架构

整体数据流设计 · 组件选型（Kafka/Flink/存… · 高可用与容错

实时风控样本管道…整体数据流设计

账户盗用检测：场景描述 · 模式设计 · 样本生成

案例实战账户盗用检测

信用卡套现检测：场景描述 · 多步骤模式 · 时间窗口设计

案例实战信用卡套现检测

营销作弊检测：场景描述 · 高频行为模式 · 设备指纹关联

案例实战营销作弊检测

实时反洗钱交易监控：场景描述 · 金额阈值+序列模式 · 多实体关联

案例实战实时反洗钱交易监…

课程总结与进阶方向

核心知识点回顾 · 生产环境注意事项 · Flink CEP未来演进

课程总结进阶方向