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

实时异常交易检测模型serving案例

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论与项目背景
什么是实时异常交易检测 · 业务价值 · 技术挑战与课程目标
课程导论项目背景
02
系统架构总览
端到端实时检测系统的分层架构设计（数… · 特征工程层 · 模型推理层
系统架构总览端到端实时检测系…
03
技术选型与工具栈
Kafka · Flink · Redis
技术选型工具栈
04
数据集构建与EDA
模拟交易数据生成 · 特征分布分析 · 标签不平衡问题可视化
EDA数据集构建
05
特征工程（上）
时间窗口特征（滑动平均 · 交易频率） · 聚合特征（用户级
特征工程时间窗口特征
06
特征工程（下）
序列特征（LSTM输入构造） · 图特征（交易网络图谱） · 特征存储到Redis
特征工程LSTM
07
模型选型与离线训练
孤立森林 · XGBoost · AutoEncoder对比实验与评估…
模型选型离线训练
08
模型导出与序列化
ONNX模型转换 · 模型版本管理 · 模型签名定义
模型导出序列化
09
模型服务框架搭建（Triton Inference Server）
Docker部署 · 模型仓库配置 · 多模型并发加载
TritonInference
10
实时特征计算管道（Flink Job）
从Kafka消费原始交易 · 滑动窗口聚合 · 调用Redis获取历史特征
FlinkJob
11
特征拼接与请求构造
Flink算子中组装特征向量 · 序列化为Protobuf/JSON · 发送至Triton
特征拼接请求构造
12
模型推理与结果解析
Triton gRPC/HTTP接口… · 解析输出分数 · 阈值判定逻辑
模型推理结果解析
13
决策引擎与规则融合
模型分数 + 硬规则（如单笔金额超限 · 高频交易）的加权决策策略
决策引擎规则融合
14
告警与通知机制
高风险交易写入Kafka告警Topi… · 触发邮件/短信/Webhook通知
告警通知机制
15
结果回写与存储
检测结果写入Elasticsearc… · 写入MySQL用于运营后台
结果回写存储
16
实时监控与可观测性
Prometheus采集Flink/… · Grafana仪表盘展示延迟 · 吞吐量
实时监控可观测性
17
端到端集成测试
模拟真实交易流 · 验证全链路延迟（<100ms） · 正确性校验
端到端集成测试模拟真实交易流
18
性能优化（上）
Flink算子链优化 · Kafka分区与并行度调优 · Triton动态批处理
性能优化Flink
19
性能优化（下）
Redis缓存预热 · 特征预计算 · 模型量化（FP16/INT8）加速推…
性能优化Redis
20
容错与高可用设计
Flink Checkpoint · Triton模型热更新 · Kafka副本机制
容错高可用设计
21
安全与合规
数据脱敏（PII字段加密） · 访问控制（RBAC） · 审计日志
安全合规
22
A/B测试与模型灰度发布
流量切分 · Shadow Mode部署 · 对比新旧模型效果
A/B测试
23
模型漂移检测与自动回滚
实时监控特征分布/模型分数分布 · 触发告警并回滚至基线版本
模型漂移检测自动回滚
24
离线重训练Pipeline
基于Airflow调度 · 从ES拉取标注数据 · 自动触发训练
Pipeline离线重训练
25
成本分析
资源估算（CPU/GPU/内存） · 云服务费用模型 · TCO优化建议
成本分析CPU/GPU
26
案例复盘
某金融公司实时反欺诈系统落地经验 · 踩坑记录与最佳实践
案例复盘某金融公司实时反…
27
扩展思考
图神经网络（GNN）在交易网络中的应… · 联邦学习保护数据隐私
扩展思考GNN
28
课程总结
核心知识点回顾 · 系统设计原则 · 面试常见问题解析
课程总结核心知识点回顾
29
动手实验1
本地Docker Compose搭建…
动手实验1Docker
30
动手实验2
使用Python脚本模拟交易流并验证…
动手实验2Python