VIP20
本课程属于：025-实时交易风控流式决策链路 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

实时风控异常交易检测模型部署教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论与风控背景
实时风控的定义 · 异常交易检测的业务价值 · 课程整体架构与学习目标
课程导论风控背景
02
风控系统技术选型
流处理引擎（Flink/Spark… · 规则引擎（Drools） · 机器学习推理框架（ONNX/Tens…
风控系统技术选型Flink/Spark
03
模型训练与导出
使用Python训练一个基于XGBo… · 并导出为ONNX格式
模型训练导出
04
ONNX模型优化与验证
使用ONNX Runtime对模型进… · 精度验证 · 确保推理速度与准确率达标
ONNX模型优化
05
Flink开发环境搭建
Flink 1.17 standal… · 配置 · 启动
Flink开发环境搭建
06
Flink CEP规则定义
使用Flink CEP库定义连续失败… · 大额转账等异常模式规则
FlinkCEP
07
模型推理UDF开发
在Flink中编写Python UD… · 加载ONNX模型进行实时评分
UDF模型推理
08
Kafka数据源接入
配置Kafka Topic作为交易流… · 设置序列化与分区策略
Kafka数据源接入
09
实时特征工程
在Flink中实现滑动窗口聚合特征（… · 金额均值）
实时特征工程Flink
10
规则引擎集成
将Drools规则引擎嵌入Flink… · 实现规则与模型的双重检测
规则引擎集成Drools
11
模型热更新机制
设计基于文件监听或配置中心的模型版本… · 实现无中断更新
模型热更新机制设计基于文件监听…
12
告警与处置通道
对接钉钉/邮件/短信告警 · 以及自动冻结账户的API回调设计
告警处置通道
13
监控与可观测性
集成Prometheus + Gra… · 吞吐量 · 模型推理耗时
监控可观测性
14
日志收集与审计
使用ELK（Elasticsearc… · Logstash · Kibana）收集风控决策日志
日志收集审计
15
压力测试与性能调优
使用JMeter模拟高并发交易 · 调整Flink并行度 · 状态后端
压力测试性能调优
16
容器化部署
编写Dockerfile打包Flin… · 使用Docker Compose编排…
容器化部署Dockerfile
17
Kubernetes集群部署
在K8s上部署Flink Sessi… · 配置资源限制与自动扩缩容
Kubernetes集群部署
18
CI/CD流水线
使用GitLab CI自动化构建 · 测试 · 部署Flink作业与模型更新
CI/CD流水线
19
多模型A/B测试
在Flink中实现流量路由 · 同时运行新旧模型并对比效果
A/B多模型
20
数据漂移检测
实现PSI（群体稳定性指标）计算 · 监控特征分布变化并触发重训练
数据漂移检测PSI
21
回测与离线评估
使用历史交易数据回放 · 评估模型与规则组合的召回率与精确率
回测离线评估
22
灰度发布策略
基于用户ID哈希或随机采样 · 逐步将流量切换到新模型
灰度发布策略ID
23
灾难恢复与容错
配置Flink Exactly-On… · 状态快照恢复 · 多副本Kafka
灾难恢复容错
24
安全与合规
数据脱敏 · 访问控制 · 审计日志保留策略
安全合规
25
成本优化
使用Spot实例 · 调整Flink内存配置 · 压缩状态后端存储
成本优化Spot
26
边缘部署场景
在IoT设备或边缘服务器上使用ONN…
边缘部署场景IoT
27
混合云部署
将模型推理部分部署在私有云 · 规则引擎在公有云 · 通过API网关互通
混合云部署将模型推理部分部…
28
全链路压测方案
设计从交易模拟器到告警输出的端到端压…
全链路压测方案设计从交易模拟器…
29
故障演练与混沌工程
注入网络延迟 · 节点宕机 · Kafka分区故障
故障演练混沌工程
30
课程总结与最佳实践
回顾关键架构决策 · 分享生产环境踩坑经验与未来演进方向
课程总结最佳实践