VIP20

本课程属于：075-反洗钱监测PSI漂移告警 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

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

反洗钱PSI漂移监测Flink应用实战

共计 30 章节

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

反洗钱与PSI概念

反洗钱监管背景 · PSI（群体稳定性指标）定义 · PSI在模型监控中的核心价值

PSI漂移监测原理

PSI计算公式推导 · 分箱策略（等距/等频） · PSI阈值设定与风险等级划分

PSI漂移监测原理

Flink实时计算基础

Flink架构概览 · DataStream API · 事件时间与处理时间

Flink实时计算基础

Flink状态管理与容错

Keyed State与Operat… · Checkpoint与Savepoi… · Exactly-Once语义保障

Flink状态管理

Flink SQL与Table API

动态表概念 · 连续查询 · Flink SQL在实时特征计算中的…

反洗钱特征工程

交易流水特征提取 · 客户画像特征 · 时间窗口聚合特征（滑动/滚动窗口）

反洗钱特征工程交易流水特征提取

PSI计算的数据准备

训练集与实时数据流对齐 · 特征分箱边界固化 · 数据标准化与缺失值处理

PSI计算的数据准备

Flink实现PSI实时计算（一）

基于DataStream API的P… · 分箱统计逻辑编码

Flink实现PSI实时计算（二）

使用Flink SQL实现PSI聚合… · 性能优化与并行度调优

PSI漂移监测告警机制

阈值触发告警 · 多级告警策略（Info/Warnin… · 告警消息推送（钉钉/邮件）

PSI漂移监测告警机制

反洗钱模型生命周期管理

模型版本管理 · 特征版本与PSI基线绑定 · 模型回滚策略

反洗钱模型生命周…模型版本管理

实时数据源接入

Kafka作为数据总线 · Avro/Protobuf序列化 · Schema Registry集成

实时数据源接入Kafka

Flink与Hudi集成

实时数仓分层（ODS/DWD/DWS… · 增量数据入湖 · PSI结果持久化

PSI漂移监测可视化

Grafana仪表盘设计 · PSI趋势折线图 · 特征分布对比直方图

PSI漂移监测可视化

反洗钱场景下的数据隐私

数据脱敏策略 · 差分隐私在PSI计算中的应用 · 合规审计日志

反洗钱场景下的数…数据脱敏策略

Flink作业部署与运维

YARN/K8s部署模式 · 作业参数调优 · 监控指标（背压/延迟/吞吐量）

Flink作业部署

PSI漂移根因分析

特征贡献度计算 · SHAP值在漂移归因中的应用 · 自动根因定位报告

PSI漂移根因分析

多模型PSI联合监测

多模型并行计算 · 模型间PSI关联分析 · 全局漂移指数

反洗钱规则引擎与PSI联动

规则引擎（Drools）集成 · PSI漂移触发规则重评估 · 动态阈值调整

PSI反洗钱规则引擎

实时特征存储

Redis/FastFeatureS… · 特征版本快照 · 低延迟特征读取

实时特征存储Redis/FastFe…

PSI漂移监测的单元测试

Mock数据生成 · Flink测试框架（TestHarn… · 断言PSI结果准确性

PSI漂移监测的单元测…

端到端集成测试

Kafka Mock · Flink MiniCluster · 模拟生产数据流

端到端集成测试Kafka

性能压测与优化

数据倾斜处理 · 异步IO优化 · 算子链与资源隔离

性能压测优化

反洗钱合规报告生成

PSI漂移日报/周报自动生成 · PDF报告模板 · 监管报送接口

反洗钱合规报告生…PSI

Flink CDC与PSI基线更新

MySQL Binlog实时捕获 · 基线数据动态更新 · 增量PSI计算

跨集群PSI监测方案

多数据中心数据同步 · Flink跨集群状态迁移 · 全局一致性视图

反洗钱模型可解释性

PSI漂移与模型性能（AUC/KS）… · 可解释性报告输出

反洗钱模型可解释…PSI

Flink ML与PSI融合

Flink ML Pipeline · 在线学习与PSI实时反馈 · 模型自动重训练触发

信用卡交易反洗钱PSI监测：需求分析 · 架构设计 · 代码实现

实战案例PSI

课程总结与展望

反洗钱技术趋势 · Flink与AI结合方向 · PSI监测最佳实践总结

课程总结反洗钱技术趋势