VIP20
本课程属于：075-反洗钱监测PSI漂移告警 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

Flink反洗钱PSI漂移告警实战课

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
反洗钱与PSI漂移概述
反洗钱业务背景 · PSI（群体稳定性指标）定义 · PSI漂移在反洗钱中的重要性
PSI反洗钱
02
Flink基础回顾
Flink核心概念（DataStre… · 时间语义 · 状态）
Flink基础回顾
03
PSI指标数学原理
PSI计算公式推导 · 分箱策略（等距分箱 · 等频分箱）
PSI指标数学原理
04
反洗钱特征工程
常见反洗钱特征（交易频次 · 金额波动 · 地域偏移）
反洗钱特征工程常见反洗钱特征
05
Flink环境搭建
Flink集群部署模式（Standa… · 开发环境（IDEA+Maven）配置
Flink环境搭建
06
Flink DataStream API入门
Source/Sink定义 · Map/FlatMap/Filter… · KeyBy与Window基础
FlinkDataStream
07
Flink状态编程
ValueState/MapStat… · 状态后端（RocksDB/Heap）…
Flink状态编程
08
Flink时间语义与Watermark
EventTime/Processi… · Watermark生成策略 · 迟到数据处理
FlinkWatermark
09
反洗钱实时数据接入
Kafka Source配置 · JSON/AVRO反序列化 · 反洗钱交易数据模型设计
反洗钱实时数据接…Kafka
10
PSI计算核心算子开发
基于Flink的PSI实时计算算子设… · 分箱统计逻辑实现
PSI计算核心算子开发
11
Flink广播状态与动态阈值
BroadcastStream模式 · 动态更新PSI阈值 · 配置中心对接
Flink广播状态
12
Flink窗口聚合与PSI计算
Tumbling/Sliding窗口… · 窗口状态清理策略
FlinkPSI
13
PSI漂移告警规则引擎
规则定义（漂移幅度 · 持续时间 · 特征维度）
PSI漂移告警规则引擎
14
Flink CEP复杂事件处理
CEP模式定义（连续漂移 · 组合特征漂移） · 告警事件生成
FlinkCEP
15
反洗钱PSI告警Sink设计
告警消息格式（JSON） · 输出到Kafka/Elasticse…
PSISink
16
Flink Checkpoint与容错机制
Exactly-Once语义 · Checkpoint配置 · 故障恢复与PSI状态一致性
FlinkCheckpoint
17
Flink SQL在PSI监控中的应用
动态表 · 窗口TVF · PSI计算的SQL化实现
FlinkSQL
18
反洗钱特征漂移可视化
PSI趋势图 · 特征分布对比图 · 告警仪表盘设计思路
反洗钱特征漂移可…PSI
19
Flink与Prometheus/Grafana集成
自定义Metric Reporter · PSI指标暴露 · 告警可视化
FlinkPrometheus/G…
20
多维度PSI漂移分析
按时间维度（小时/天/周） · 按客群维度（高/中/低风险） · 按渠道维度
PSI多维度
21
反洗钱PSI漂移告警降噪
告警聚合 · 告警抑制 · 基于历史模式的误报过滤
PSI反洗钱
22
Flink作业性能调优
并行度设置 · 算子链优化 · 反压处理
Flink作业性能调优
23
Flink作业监控与运维
JobManager/TaskMan… · Web UI指标解读 · 作业重启策略
Flink作业监控
24
反洗钱PSI漂移告警实战案例一
交易金额特征漂移告警（场景描述 · 代码实现 · 效果展示）
PSI反洗钱
25
反洗钱PSI漂移告警实战案例二
交易地域特征漂移告警（场景描述 · 代码实现 · 效果展示）
PSI反洗钱
26
反洗钱PSI漂移告警实战案例三
交易时间间隔特征漂移告警（场景描述 · 代码实现 · 效果展示）
PSI反洗钱
27
Flink与机器学习模型联动
PSI漂移触发模型重训练 · 模型版本管理 · 在线学习架构
Flink机器学习模型联动
28
反洗钱PSI漂移告警系统架构设计
整体架构图（数据流 · 组件 · 存储）
PSI反洗钱
29
Flink反洗钱PSI漂移告警测试
单元测试（算子测试） · 集成测试（端到端流程） · 性能测试
FlinkPSI
30
课程总结与最佳实践
PSI漂移告警落地经验 · 常见坑点 · 未来演进方向（实时特征库
课程总结最佳实践