VIP20
本课程属于：047-实时交易风控人群切片复盘 金融科技风控与量化工程 · 共 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 · PatternStream · select与flatSelect
FlinkCEP
05
个体模式定义
单例模式 · 循环模式 · 量词（times
个体模式定义单例模式
06
条件与约束
简单条件 · 迭代条件 · 组合条件
条件约束
07
模式序列与组合
严格连续 · 松散连续 · 非确定性松散连续
模式序列组合
08
模式组与嵌套
模式组定义 · 复杂业务场景下的模式嵌套
模式组嵌套
09
事件选择与跳过策略
skip策略详解（skip_past… · skip_to_first · skip_to_last
事件选择跳过策略
10
CEP结果处理
select与flatSelect区… · 输出模式匹配结果 · 超时事件处理
CEP结果处理
11
实时风控系统架构
数据采集层 · 计算层 · 决策层
实时风控系统架构数据采集层
12
人群切片定义与价值
什么是人群切片 · 切片粒度 · 切片在风控中的作用
人群切片定义价值
13
基于CEP的切片引擎设计
事件流接入 · 模式匹配 · 切片规则
CEP基于
14
切片规则配置化
规则引擎设计 · 规则动态更新 · 规则版本管理
切片规则配置化规则引擎设计
15
切片状态存储与恢复
Flink状态后端选择（RocksD… · Checkpoint与Savepoi…
切片状态存储恢复
16
切片结果输出与下游对接
Kafka Sink · HBase Sink · MySQL Sink
切片结果输出下游对接
17
实时特征计算与切片结合
滑动窗口特征 · 计数特征 · 比率特征
实时特征计算切片结合
18
风控场景一
登录风控——异地登录检测 · 暴力破解检测 · 设备指纹切片
风控场景一登录风控
19
风控场景二
交易风控——大额交易 · 高频交易 · 洗钱模式识别
风控场景二交易风控
20
风控场景三
营销风控——薅羊毛检测 · 黑产团伙识别 · 优惠券滥用
风控场景三营销风控
21
风控场景四
内容风控——垃圾评论 · 刷屏行为 · 恶意注册
风控场景四内容风控
22
复杂事件序列优化
模式匹配性能调优 · 状态大小控制 · 并行度设置
复杂事件序列优化模式匹配性能调优
23
CEP与机器学习融合
规则+模型双引擎 · 模型打分切片 · 动态阈值
CEP机器学习融合
24
实时风控数据血缘与回溯
事件溯源 · 切片回溯 · 问题排查
实时风控数据血缘回溯
25
Flink CEP监控与告警
Metrics监控 · 延迟告警 · 失败重试
FlinkCEP
26
多流关联与CEP
ConnectedStreams · BroadcastStream · 维表Join
CEP多流关联
27
CEP在云原生环境部署
Kubernetes部署 · 资源隔离 · 弹性伸缩
CEP云原生环境部署
28
大规模集群实战
千万级QPS下的CEP优化 · 数据倾斜处理 · 反压处理
大规模集群实战QPS
29
案例实战
构建一个完整的实时风控人群切片系统（…
案例实战构建一个完整的实…
30
课程总结与展望
CEP未来趋势 · Flink 2.0新特性 · 实时风控演进方向
课程总结CEP