01
实时异常交易检测概述
什么是实时异常交易检测 · 业务场景与挑战 · 技术选型与架构概览
基础概念
02
实时数据流基础
Kafka核心概念 · 生产者与消费者 · 主题与分区 · Python操作Kafka实战
Kafka数据流
03
实时计算引擎
Flink核心概念 · DataStream API · 时间语义与水位线 · Python PyFlink入门
Flink计算
04
特征工程实战
滑动窗口统计 · 实时特征计算 · 特征存储与更新 · 特征重要性评估
特征工程
05
异常检测算法
统计方法(Z-Score/IQR) · 孤立森林/LOF · AutoEncoder
算法ML
06
规则引擎设计
规则定义与配置 · 匹配引擎 · 规则热更新 · 效果评估
规则引擎
07
模型部署与推理
模型序列化与加载 · ONNX转换 · 实时推理服务 · 版本管理
部署推理
08
实时监控与告警
监控指标体系 · 告警规则配置 · 通知渠道 · 监控大盘设计
监控告警
09
系统性能优化
数据倾斜处理 · 背压机制 · 状态后端优化 · 资源动态调整
性能优化
10
实战案例一：信用卡盗刷检测
系统设计与实现 · 实时风控流水线
实战信用卡
11
实战案例二：电商交易欺诈检测
系统设计与实现 · 电商风控实战
实战电商
12
实战案例三：加密货币异常检测
系统设计与实现 · 链上数据实时分析
实战加密货币
13
数据质量保障
完整性校验 · 延迟处理 · 去重策略 · 脏数据处理
数据质量保障
14
A/B测试与灰度发布
实验设计 · 流量切分 · 效果评估 · 回滚机制
实验灰度
15
安全与合规
数据脱敏 · 隐私计算 · 审计日志 · 合规要求
安全合规
16
分布式协调
ZooKeeper应用 · 一致性保证 · 故障恢复
协调ZK
17
存储选型
HBase/Redis/Elasticsearch角色与对比
存储选型
18
消息队列进阶
Kafka Exactly-Once · 事务消息 · 幂等生产者
Kafka进阶
19
状态管理与容错
Flink Checkpoint/Savepoint · 状态后端 · 故障恢复
状态容错
20
实时特征平台建设
特征中心 · 特征服务 · 特征血缘 · 特征复用
特征平台架构
21
模型生命周期管理
训练 · 评估 · 上线 · 监控 · 退役
MLOps生命周期
22
实时计算与批处理融合
Lambda/Kappa架构 · 流批一体实践
架构融合
23
复杂事件处理(CEP)
模式定义 · 事件序列匹配 · 超时处理 · 实战案例
CEP事件
24
图计算在异常检测中的应用
图构建 · 社区发现/PageRank · 实时图更新
图计算检测
25
强化学习在风控中的应用
环境建模 · 奖励设计 · 策略学习 · 在线更新
强化学习风控
26
多模态数据融合
结构化/文本/图像/时序融合策略
多模态融合
27
可解释性AI
SHAP值 · 特征重要性可视化 · 决策路径 · 报告生成
XAI可解释
28
混沌工程在实时系统中的应用
故障注入 · 稳定性测试 · 弹性设计 · 演练复盘
混沌稳定性
29
成本优化
资源评估 · 弹性伸缩 · Spot实例 · 数据压缩与降采样
成本优化
30
未来趋势
联邦学习 · 隐私计算 · 大模型风控 · 实时决策平台演进
趋势前沿