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

批流一体风控系统从入门到实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
风控系统概述
什么是风控系统 · 风控系统的核心目标 · 批流一体的概念与价值
风控系统概述什么是风控系统
02
技术栈选型
批流一体主流技术（Flink · Spark Streaming · Kafka
技术栈选型Flink
03
实时计算基础
Flink核心概念（DataStre… · Operator · Window
实时计算基础Flink
04
批处理基础
Spark SQL与DataSet… · 批处理ETL流程 · 与实时计算的异同
批处理基础Spark
05
数据源接入
Kafka作为事件总线 · Kafka Topic设计 · 消息序列化（Avro/Protobu…
数据源接入Kafka
06
离线数仓分层
ODS/DWD/DWS/ADS设计 · Hive与Hudi表格式 · 分区策略
离线数仓分层ODS/DWD/DWS/…
07
实时数仓分层
实时ODS/DWD/DWS设计 · Kafka Stream与Flink… · 维表关联
实时数仓分层ODS/DWD/DWS
08
批流统一存储
Apache Hudi核心概念（Co… · Incremental Query · Time Travel
批流统一存储Apache
09
规则引擎设计
规则模型定义（条件 · 动作 · 优先级）
规则引擎设计规则模型定义
10
特征工程
实时特征（滑动窗口计数 · 状态特征） · 离线特征（历史聚合
特征工程实时特征
11
决策树与评分卡
决策树在风控中的应用 · 评分卡构建流程 · WOE与IV计算
决策树评分卡
12
机器学习模型集成
模型训练（XGBoost/Light… · 模型部署（PMML/ONNX） · 实时推理Pipeline
机器学习模型集成XGBoost/Ligh…
13
实时反欺诈场景
交易反欺诈 · 设备指纹 · 行为序列异常检测
实时反欺诈场景交易反欺诈
14
离线反洗钱场景
可疑交易识别 · 团伙挖掘（图算法） · 监管报表生成
离线反洗钱场景可疑交易识别
15
批流一体架构设计
Lambda架构 vs Kappa架… · 批流一体统一数据管道设计
批流一体架构设计Lambda
16
Flink SQL实战
创建Kafka Source Tab… · 定义Window Aggregati… · 写入Hudi Sink
FlinkSQL
17
Spark Structured Streaming实战
读取Kafka流 · 状态管理 · 写入Hudi
SparkStructured
18
Hudi实战
使用Spark写入Hudi表 · Incremental Pull · Clustering与Compact…
HudiSpark
19
规则引擎实战
基于Flink CEP实现复杂事件匹… · 规则动态更新
规则引擎实战Flink
20
实时特征计算实战
使用Flink实现滑动窗口计数 · 使用Redis存储特征
实时特征计算实战Flink
21
模型推理实战
使用Flink ProcessFun… · 模型版本管理
模型推理实战Flink
22
数据质量监控
实时数据延迟监控 · 离线数据完整性校验 · 异常告警
数据质量监控实时数据延迟监控
23
全链路追踪
基于OpenTelemetry的Tr… · 日志聚合 · 性能瓶颈分析
全链路追踪OpenTelemetr…
24
灰度发布与A/B测试
规则灰度 · 模型A/B测试 · 流量切分策略
A/B灰度发布
25
监控与告警
Prometheus + Grafa… · 自定义告警规则
监控告警
26
安全与权限
数据脱敏 · 访问控制（RBAC） · 审计日志
安全权限
27
项目实战一
实时交易风控系统（从Kafka接入到…
项目实战一Kafka
28
项目实战二
离线反洗钱分析（Spark读取Hud… · 进行团伙挖掘与报表生成）
项目实战二Spark
29
项目实战三
批流一体统一风控平台（整合实时与离线… · 统一规则与特征管理）
项目实战三批流一体统一风控…
30
总结与展望
批流一体风控的未来趋势 · 云原生与Serverless风控 · AI驱动风控
批流一体风控的未…Serverless