VIP20

本课程属于：082-支付风控策略批次偏移诊断 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

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

Flink实时批次监控：支付风控漂移检测方法

共计 30 章节

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

支付风控漂移检测概述

什么是风控漂移 · 漂移检测在支付场景中的重要性 · 实时批次监控的核心理念

支付风控漂移检测…什么是风控漂移

Flink基础回顾

Flink架构 · DataStream与DataSet… · 事件时间与处理时间

Flink基础回顾

Flink批流一体架构

Batch on Streaming… · DataSet API与DataSt… · Flink 1.12+批流统一

Flink批流一体架构

支付风控数据模型

交易事件模型 · 用户画像特征 · 设备指纹

支付风控数据模型交易事件模型

漂移检测指标定义

统计漂移（均值/方差） · 分布漂移（KL散度/JS散度） · 模型漂移（PSI/CSI）

漂移检测指标定义统计漂移

实时批次数据源接入

Kafka Source配置 · JDBC Source用于历史批次 · File Source用于离线回放

实时批次数据源接…Kafka

Flink时间语义与窗口

事件时间窗口 · 滑动窗口与滚动窗口 · Session窗口在漂移检测中的应用

Flink时间语义

批次数据预处理

数据清洗 · 缺失值处理 · 异常值过滤

批次数据预处理数据清洗

实时统计漂移检测

滑动窗口均值/方差计算 · 与历史基线对比 · 阈值告警机制

实时统计漂移检测滑动窗口均值

分布漂移检测实现

KL散度实时计算 · JS散度近似算法 · 直方图近似方法

分布漂移检测实现KL

模型漂移检测实现

PSI（群体稳定性指标）计算 · CSI（特征稳定性指标）计算 · 模型分数分布对比

模型漂移检测实现PSI

Flink状态后端与Checkpoint

状态存储选择（RocksDB/Hea… · Checkpoint配置 · Exactly-Once语义保障

FlinkCheckpoint

多维度漂移检测

时间维度（小时/天/周） · 空间维度（地区/渠道） · 用户维度（新老客/等级）

多维度漂移检测时间维度

漂移检测告警与通知

告警规则引擎 · 钉钉/邮件/短信通知集成 · 告警降噪策略

漂移检测告警通知

Flink CEP复杂事件处理

CEP模式定义 · 漂移事件序列匹配 · 时序关联规则

实时漂移检测Pipeline架构

Source → Transform…

Pipeline实时漂移检测

Flink SQL在漂移检测中的应用

动态表与连续查询 · 窗口聚合SQL · UDF自定义漂移函数

历史批次回放与对比

离线批次数据加载 · 与实时流对比分析 · 漂移趋势可视化

历史批次回放对比

漂移检测结果存储

Elasticsearch存储指标 · InfluxDB时序存储 · HBase存储原始事件

漂移检测结果存储Elasticsearc…

Flink监控与运维

Metrics系统 · Prometheus+Grafana… · 任务重启策略与容错

漂移检测性能优化

并行度调优 · 数据倾斜处理 · 算子链优化

漂移检测性能优化并行度调优

多模型集成检测

规则模型+统计模型+机器学习模型 · 模型融合策略 · 投票机制

多模型集成检测规则模型+统计模…

实时特征漂移检测

特征分布对比 · 特征重要性变化 · 特征缺失率监控

实时特征漂移检测特征分布对比

漂移检测A/B实验

实验分组设计 · 指标对比 · 显著性检验

A/B漂移检测

Flink与AI平台集成

TensorFlow/PyTorch… · Model Serving · 在线推理

漂移检测数据可视化

Grafana仪表盘设计 · 实时曲线图 · 热力图

漂移检测数据可视…Grafana

大规模支付场景实战

千万级TPS下的漂移检测 · 资源估算 · 架构选型

大规模支付场景实…TPS

漂移检测自动化运维

自动扩缩容 · 自动调参 · 自动回滚策略

漂移检测自动化运…自动扩缩容

漂移检测安全与合规

数据脱敏 · 隐私保护 · 审计日志

漂移检测安全合规

课程总结与未来展望

漂移检测技术趋势 · Flink社区发展 · AI+实时风控融合方向

课程总结未来展望