VIP20
本课程属于：082-支付风控策略批次偏移诊断 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

商户风险批次诊断：Flink实时漂移监控实践

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
商户风险批次诊断的背景与挑战 · Flink实时漂移监控的价值
课程导论商户风险批次诊断…
02
风险漂移概念
什么是数据漂移 · 概念漂移 · 模型漂移
风险漂移概念什么是数据漂移
03
Flink核心原理回顾
DataStream API · 时间语义 · Watermark机制
Flink核心原理回顾
04
实时数据接入
Kafka作为数据源 · Flink消费商户交易与行为日志
实时数据接入Kafka
05
数据预处理
实时ETL清洗 · 字段标准化 · 异常值过滤
数据预处理ETL
06
特征工程实时化
滑动窗口统计 · 实时聚合特征（交易频次 · 金额波动）
特征工程实时化滑动窗口统计
07
批次诊断定义
如何定义一次“风险批次 · 批次窗口的划分策略（固定/会话/滑动…
批次诊断定义如何定义一次“风…
08
漂移检测算法
KS检验 · PSI（群体稳定性指标）在Flink…
漂移检测算法KS
09
实时PSI计算
分箱逻辑 · 分布统计 · Flink KeyedProcess…
PSI实时
10
实时KS计算
累计分布函数计算 · 最大距离求解 · Flink算子链优化
KS实时
11
多维度漂移监控
按商户 · 行业 · 渠道
多维度漂移监控按商户
12
基线构建
历史数据离线训练基线 · Flink加载基线配置进行实时对比
基线构建历史数据离线训练…
13
告警阈值设计
动态阈值 vs 静态阈值 · 基于百分位数的自适应阈值
告警阈值设计vs
14
Flink CEP复杂事件处理
定义漂移事件模式 · 检测连续漂移或突发漂移
FlinkCEP
15
状态管理与容错
Checkpointing · Savepoint · Exactly-Once语义保障
状态管理容错
16
Flink SQL在漂移监控中的应用
使用窗口聚合 · MATCH_RECOGNIZE进行模…
FlinkSQL
17
实时特征存储
使用Redis/HBase存储商户画… · Flink异步IO查询
实时特征存储Redis/HBase
18
漂移根因分析
下钻分析（Drill-down） · 定位是哪个特征或子群体导致漂移
漂移根因分析Drill-down
19
可视化与看板
将漂移指标输出到Elasticsea… · 通过Grafana实时展示
可视化看板
20
案例实战一
交易金额漂移检测——从Kafka接入…
案例实战一Kafka
21
案例实战二
商户登录行为漂移检测——基于会话窗口…
案例实战二商户登录行为漂移…
22
案例实战三
多商户批量诊断——Flink广播流分…
案例实战三Flink
23
性能优化
反压处理 · 算子链优化 · KeyBy倾斜解决方案
性能优化反压处理
24
数据倾斜处理
自定义Partitioner · 两阶段聚合 · MiniBatch优化
数据倾斜处理Partitioner
25
Flink与机器学习模型集成
实时调用PMML/ONNX模型进行风…
Flink机器学习模型集成
26
模型漂移监控
监控模型输出分数的分布变化 · 触发模型重训练
模型漂移监控监控模型输出分数…
27
生产环境部署
Flink on YARN/K8s · 资源隔离与动态扩缩容
生产环境部署Flink
28
监控与运维
Flink Metrics · 日志采集 · 任务重启策略
监控运维
29
最佳实践总结
常见坑点 · 设计模式 · 代码规范
最佳实践总结常见坑点
30
课程总结与展望
实时漂移监控的未来趋势 · 与AI Agent的结合
课程总结实时漂移监控的未…