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

Flink CEP异常交易样本构建指南

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
Flink CEP在金融风控中的价值 · 异常交易检测的挑战 · 本课程的学习目标与前置知识
课程导论Flink
02
Flink基础回顾
Flink架构 · DataStream API核心概念 · 时间语义与Watermark机制
Flink基础回顾
03
CEP概念精讲
事件 · 模式 · 模式序列
CEP概念精讲
04
Flink CEP核心API
Pattern API详解 · 包括begin · next
FlinkCEP
05
模式定义与组合
单例模式 · 循环模式（times · oneOrMore
模式定义组合
06
条件与约束
简单条件 · 迭代条件 · 子类型条件
条件约束
07
时间窗口与超时
within子句 · 时间窗口对齐 · 超时事件的处理与侧输出流
时间窗口超时
08
跳过策略详解
跳过策略（skip strategy… · NO_SKIP · SKIP_PAST_LAST_EVE…
跳过策略详解skip
09
事件选择与提取
select与flatSelect函… · 输出类型定义 · 匹配事件的字段提取
事件选择提取
10
异常交易样本定义
什么是异常交易样本 · 样本的构成要素（时间戳 · 账户
异常交易样本定义什么是异常交易样…
11
样本构建流程总览
数据采集→数据清洗→特征工程→模式匹…
样本构建流程总览数据采集→数据清…
12
数据源接入
Kafka Source配置 · JSON/AVRO反序列化 · 事件时间戳分配与Watermark生…
数据源接入Kafka
13
数据预处理
过滤无效交易 · 去重 · 字段补齐
数据预处理过滤无效交易
14
特征工程基础
滑动窗口聚合特征（如交易频次 · 金额均值） · 状态特征（如历史行为画像）
特征工程基础滑动窗口聚合特征
15
常见异常模式一
短时间内高频交易（刷单检测） · 定义模式 · 设置时间窗口与阈值
常见异常模式一短时间内高频交易
16
常见异常模式二
异地登录后立即交易（地理异常） · 结合地理位置与时间差构建模式
常见异常模式二异地登录后立即交…
17
常见异常模式三
大额转账后快速分散（洗钱模式） · 使用followedBy与循环模式
常见异常模式三大额转账后快速分…
18
常见异常模式四
设备指纹突变（设备异常） · 检测同一账户短时间内设备ID变化
常见异常模式四设备指纹突变
19
复杂模式组合
多模式嵌套 · 模式序列的AND/OR逻辑 · 模式之间的时间关联
复杂模式组合多模式嵌套
20
样本标签生成
正样本（异常交易）与负样本（正常交易…
样本标签生成正样本
21
样本增强与平衡
过采样 · 欠采样 · 合成样本（SMOTE）在CEP样本中…
样本增强平衡
22
样本输出与存储
将匹配结果写入Kafka · HDFS · MySQL或Elasticsearc…
样本输出存储
23
状态管理与容错
Flink状态后端配置 · Checkpoint与Savepoi…
状态管理容错
24
CEP作业性能优化
并行度设置 · 模式剪枝 · 状态大小控制
CEP作业性能优化
25
CEP作业监控与调优
Metrics监控 · 延迟分析 · 反压处理
CEP作业监控
26
实战案例一
信用卡盗刷检测 · 从数据流接入到样本生成完整代码实现
实战案例一信用卡盗刷检测
27
实战案例二
账户登录异常检测 · 结合设备指纹与IP地址的CEP模式
实战案例二账户登录异常检测
28
实战案例三
内部人员违规交易检测 · 基于角色与权限的复杂事件模式
实战案例三内部人员违规交易…
29
测试与验证
单元测试CEP模式 · 模拟数据生成 · 样本质量评估（精确率
测试验证
30
课程总结与进阶
Flink CEP与机器学习结合 · 动态规则更新 · 未来趋势与学习路径
课程总结进阶