VIP20

本课程属于：025-实时交易风控流式决策链路 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

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

Flink CEP异常交易检测实战教程

共计 30 章节

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

Flink CEP在金融风控中的价值 · 异常交易检测场景概述 · 课程目标与前置知识要求

课程导学Flink

Flink基础回顾

Flink架构 · DataStream API核心概念 · Flink运行环境搭建（Standa…

Flink基础回顾

Flink时间语义

EventTime · ProcessingTime · IngestionTime的区别与选…

Flink时间语义

Flink窗口机制

滚动窗口 · 滑动窗口 · 会话窗口

Flink窗口机制

CEP概念入门

什么是复杂事件处理（CEP） · CEP与普通流处理的区别 · Flink CEP核心组件（Patt…

CEP概念入门

Pattern API基础

Pattern定义 · begin/where/or/not…

Pattern组合与序列

严格连续（next） · 宽松连续（followedBy） · 非确定性宽松连续（followedB…

CEP时间约束

within子句 · 时间窗口与模式匹配的关联 · 超时事件处理

CEP时间约束

CEP条件进阶

迭代条件（IterativeCond… · 简单条件（SimpleConditi… · 组合条件（And/Or）

CEP条件进阶

CEP输出与处理

PatternSelectFunct… · PatternFlatSelectF… · PatternTimeoutFunc…

异常交易场景定义

常见异常交易模式（小额试探 · 大额突增 · 高频交易

异常交易场景定义常见异常交易模式

数据模型设计

交易事件数据结构（Transacti… · 用户画像数据 · 规则配置表设计

数据模型设计Transacti

数据源接入

Kafka数据源配置 · JSON反序列化 · 自定义Deserialization…

数据源接入Kafka

水位线策略实战

针对交易事件设置合理的水位线 · 处理乱序数据 · 允许延迟与侧输出

水位线策略实战针对交易事件设置…

小额试探后大额盗刷——定义Patte… · within时间窗口 · 输出告警

短时间内高频交易——使用times算… · 滑动窗口统计 · 阈值判断

异地登录+异常交易——关联用户登录流… · 使用followedByAny

模式三异地登录+异常交…

设备指纹突变——设备ID变更检测 · 结合CEP与状态变量

夜间交易异常——时间条件过滤 · 结合ProcessFunction进…

模式五夜间交易异常

多规则并行匹配

使用PatternStream的un… · 不同规则输出到不同侧输出流

多规则并行匹配PatternStrea…

规则动态更新

从外部配置中心（如Nacos/Zoo… · BroadcastStream模式

规则动态更新Nacos/Zoo

状态管理与容错

Flink状态后端（RocksDB） · Checkpoint与Savepoi… · Exactly-Once语义保障

状态管理容错

告警与通知

告警事件序列化 · 输出到Kafka告警Topic · 集成钉钉/邮件通知

KeyBy策略优化 · Pattern剪枝 · 并行度调优

性能优化KeyBy

监控与运维

Flink Web UI指标解读 · Prometheus+Grafana… · 日志采集与告警

单元测试与集成测试

CEP模式测试 · 使用TestHarness模拟事件流 · 断言匹配结果

单元测试集成测试

案例实战一

信用卡盗刷检测——结合模式一 · 二 · 三

案例实战一信用卡盗刷检测

案例实战二

账户登录异常检测——登录失败次数 · IP地理变化 · 设备变化综合检测

案例实战二账户登录异常检测

案例实战三

洗钱交易链检测——多层转账 · 金额累加 · 时间窗口嵌套

案例实战三洗钱交易链检测

课程总结与进阶

Flink CEP局限性 · 与SQL CEP对比 · 未来趋势（机器学习+CEP）

课程总结进阶