VIP20

本课程属于：047-实时交易风控人群切片复盘 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

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

Flink CEP异常交易实时风控实战

共计 30 章节

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

实时风控背景 · Flink CEP在金融风控中的价值 · 课程目标与前置知识

课程导论实时风控背景

Flink基础回顾

Flink架构 · DataStream API · 时间语义

Flink基础回顾

CEP概念入门

什么是复杂事件处理 · CEP核心术语（事件 · 模式

CEP概念入门

Flink CEP核心API

Pattern API概览 · Pattern定义 · Pattern序列

Flink CEP模式匹配

简单匹配 · 循环匹配 · 条件匹配

Flink CEP模式跳过策略

skip策略详解 · next/times/or/cons…

Flink CEP事件选择与输出

select · flatSelect · process函数

Flink CEP状态管理与容错

CEP算子状态 · Checkpoint与Savepoi… · Exactly-Once语义

Flink CEP性能优化

并行度设置 · 事件时间优化 · 状态大小控制

实时风控系统架构设计

整体架构图 · 数据源层 · 计算层

实时风控系统架构…整体架构图

风控数据源接入

Kafka作为事件源 · JSON/AVRO序列化 · Schema Registry集成

风控数据源接入Kafka

交易事件模型设计

交易事件字段定义 · 事件类型枚举 · 时间戳处理

交易事件模型设计交易事件字段定义

规则引擎设计

规则定义语言 · 规则存储（MySQL/Redis） · 规则热加载

规则引擎设计规则定义语言

单笔交易风控规则实现

大额交易检测 · 高频交易检测 · 跨地域交易检测

单笔交易风控规则…大额交易检测

序列模式风控规则实现

登录后立即交易 · 多次失败后成功 · 短时间多设备登录

序列模式风控规则…登录后立即交易

时间窗口风控规则实现

滑动窗口累计金额 · Tumbling窗口次数统计 · Session窗口行为分析

时间窗口风控规则…滑动窗口累计金额

复杂风控规则实现

多事件组合匹配 · 事件间时间差约束 · 事件属性关联

复杂风控规则实现多事件组合匹配

风控规则动态更新

规则变更监听 · CEP模式动态重建 · 无停机切换

风控规则动态更新规则变更监听

风控结果输出与告警

告警级别定义 · 告警渠道（短信/邮件/Webhook… · 告警去重与聚合

风控结果输出告警

风控结果存储与回溯

结果写入Elasticsearch · HBase存储详情 · ClickHouse分析查询

风控结果存储回溯

风控系统监控与运维

Flink作业监控 · 延迟监控 · 吞吐量监控

风控系统监控运维

风控系统测试策略

单元测试 · 集成测试 · 压力测试

风控系统测试策略单元测试

风控系统安全与合规

数据脱敏 · 审计日志 · 权限控制

风控系统安全合规

实战案例一

账户盗刷检测——多设备登录+大额转账…

实战案例一账户盗刷检测

实战案例二

信用卡套现检测——短时间多笔整数金额…

实战案例二信用卡套现检测

实战案例三

洗钱行为检测——多层转账+金额递增+…

实战案例三洗钱行为检测

实战案例四

薅羊毛检测——新用户注册+首单优惠+…

实战案例四薅羊毛检测

Flink CEP与机器学习结合

规则评分+ML模型分数 · CEP触发ML推理 · 实时特征工程

Flink CEP与图计算结合

交易关系图 · 团伙检测 · 循环转账检测

课程总结与展望

Flink CEP未来趋势 · 实时风控发展方向 · 推荐学习资源

课程总结Flink