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

Flink实时PSI计算：支付风控批次偏移预警实战

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
PSI概念 · 批次偏移风险 · Flink在支付风控中的价值
课程导论PSI
02
支付风控场景分析
交易欺诈 · 盗刷 · 团伙攻击与批次偏移的关系
支付风控场景分析交易欺诈
03
PSI数学原理
群体稳定性指标公式 · 分箱方法 · 期望值与实际值对比
PSI数学原理
04
Flink实时计算基础
DataStream API · 时间语义 · Watermark机制
Flink实时计算基础
05
Flink状态后端与容错
RocksDB状态后端 · Checkpoint与Savepoi…
Flink状态后端
06
批次偏移定义
批次数据延迟 · 乱序到达 · 窗口聚合偏移的量化指标
批次偏移定义批次数据延迟
07
实时PSI计算架构设计
数据源层 · 计算层 · 存储层
PSI实时
08
数据源接入
Kafka Source · Schema Registry · Avro/Proto序列化
数据源接入Kafka
09
特征工程与分箱策略
等频分箱 · 等距分箱 · 自定义分箱在Flink中的实现
特征工程分箱策略
10
Flink窗口聚合
Tumbling Window · Sliding Window · Session Window在PSI…
Flink窗口聚合
11
实时PSI核心算子开发
MapFunction · RichMapFunction · ProcessFunction
PSI实时
12
批次偏移检测算法
基于滑动窗口的偏移量计算 · 阈值动态调整
批次偏移检测算法基于滑动窗口的偏…
13
Flink CEP复杂事件处理
检测连续批次偏移 · 模式匹配
FlinkCEP
14
状态管理与广播变量
BroadcastStream分发参… · KeyedState存储实时分布
状态管理广播变量
15
实时告警机制
基于Sink的告警推送 · Webhook · 钉钉/企微机器人
实时告警机制Sink
16
Flink SQL实现PSI
使用SQL窗口函数 · UDF自定义聚合函数
FlinkSQL
17
性能优化
算子链 · 并行度调优 · 反压处理
性能优化算子链
18
数据倾斜处理
KeyBy优化 · Salting技术 · 两阶段聚合
数据倾斜处理KeyBy
19
容错与Exactly-Once语义
端到端一致性 · Kafka事务写入
Exactly-Once容错
20
监控与运维
Flink Metrics · Prometheus+Grafana…
监控运维
21
实战案例一
信用卡交易实时PSI监控与偏移预警
实战案例一PSI
22
实战案例二
支付渠道切换时的批次偏移检测
实战案例二支付渠道切换时的…
23
实战案例三
大促活动期间流量突增的PSI异常告警
实战案例三PSI
24
实战案例四
多维度（商户 · 地区 · 设备）PSI联合分析
实战案例四多维度
25
测试与验证
单元测试 · 集成测试 · 模拟数据回放
测试验证
26
部署与发布
Flink on YARN/K8s · 滚动升级 · 版本管理
部署发布
27
数据可视化
实时PSI仪表盘 · 偏移趋势图 · 热力图
数据可视化PSI
28
最佳实践
分箱数量选择 · 窗口大小调优 · 告警阈值设定
最佳实践分箱数量选择
29
常见问题与排错
数据丢失 · 状态膨胀 · 延迟飙升
常见问题排错
30
课程总结与展望
实时PSI在风控领域的未来 · 联邦学习与隐私计算
课程总结PSI