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

Flink实时风控流式决策链路实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
风控概述
实时风控的业务背景 · 常见风险类型（欺诈 · 盗刷
风控概述实时风控的业务背…
02
Flink基础回顾
Flink架构 · DataStream API · 时间语义
Flink基础回顾
03
实时风控技术选型
Flink vs Spark Str… · 选型依据与场景匹配
实时风控技术选型Flink
04
风控数据源接入
Kafka作为事件源 · JSON/AVRO序列化 · Schema Registry集成
风控数据源接入Kafka
05
事件预处理
数据清洗 · 字段补齐 · 时间戳标准化
事件预处理数据清洗
06
特征工程概述
实时特征与离线特征的区别 · 滑动窗口特征 · 计数/求和/均值特征
特征工程概述实时特征
07
Flink SQL实时特征计算
使用Flink SQL定义滑动窗口 · Tumble/Hop窗口 · Over窗口聚合特征
FlinkSQL
08
CEP复杂事件处理
Flink CEP基础 · Pattern API · 连续事件匹配（如
CEP复杂事件处理
09
规则引擎设计
规则模型定义（条件 · 动作 · 优先级）
规则引擎设计规则模型定义
10
Flink动态规则加载
基于广播流（BroadcastStr…
Flink动态规则加载
11
决策树与规则链
规则链编排 · 决策树节点设计 · 命中/未命中分支逻辑
决策树规则链
12
实时评分卡模型
逻辑回归评分卡 · Flink模型推理（PMML/ONN… · 模型版本管理
实时评分卡模型逻辑回归评分卡
13
机器学习模型集成
Flink与TensorFlow/P… · 模型服务调用（gRPC/REST）
机器学习模型集成Flink
14
风控变量存储
Redis实时变量缓存 · HBase历史画像存储 · 变量TTL策略
风控变量存储Redis
15
实时画像系统
用户/设备画像构建 · 标签聚合 · 画像更新与过期机制
实时画像系统用户
16
风控决策结果输出
决策结果写入Kafka · MySQL · Elasticsearch
风控决策结果输出Kafka
17
风控监控与告警
Flink作业监控（延迟 · 吞吐 · 背压）
风控监控告警
18
风控链路追踪
基于OpenTelemetry的Tr… · 决策链路日志 · 问题排查
风控链路追踪OpenTelemetr…
19
反欺诈场景实战
登录风控——设备指纹 · IP信誉 · 行为序列异常检测
反欺诈场景实战登录风控
20
交易风控实战
大额交易拦截 · 频繁交易检测 · 地理围栏异常
交易风控实战大额交易拦截
21
信贷风控实战
申请反欺诈 · 多头借贷检测 · 收入负债比实时计算
信贷风控实战申请反欺诈
22
营销风控实战
薅羊毛检测 · 红包/优惠券滥用 · 同设备多账号识别
营销风控实战薅羊毛检测
23
风控数据湖集成
Flink写入Hudi/Iceber… · 历史数据回溯分析
风控数据湖集成Flink
24
Flink状态管理与优化
状态大小控制 · RocksDB调优 · 增量Checkpoint
Flink状态管理
25
Flink调优实战
并行度设置 · 算子链 · 缓冲区调优
Flink调优实战
26
多流Join与关联
Interval Join · Temporal Join · 维表Join（Redis/MySQL…
Join多流
27
风控测试与仿真
回放测试 · 模拟流量注入 · 规则覆盖率测试
风控测试仿真
28
灰度发布与A/B测试
风控策略灰度 · Flink作业多版本并行 · 流量切分
A/B灰度发布
29
生产环境运维
作业部署（YARN/K8s） · 日志收集 · 故障恢复
生产环境运维YARN/K8s
30
风控架构演进
从单体规则到AI驱动 · 实时决策平台建设 · 未来趋势（联邦学习
风控架构演进AI