事件驱动风控模型实战

📚 共计 30 章节

事件驱动风控概述

什么是事件驱动 · 与传统风控的区别 · 核心应用场景

实时事件流架构

Kafka核心概念 · Topic与Partition设计 · 生产者与消费者模型

事件采集与接入

埋点设计原则 · SDK接入规范 · 数据上报可靠性保障

事件标准化

事件Schema设计 · 字段映射与清洗 · 事件ID生成策略

事件存储选型

HBase vs ClickHouse vs Elasticsearch · 存储模型对比

事件时间语义

事件时间 · 处理时间 · 摄入时间 · Watermark机制

时间语义Watermark

Flink事件处理基础

DataStream API · Source与Sink · 事件序列化

CEP复杂事件处理

Flink CEP核心概念 · Pattern API · 匹配与输出

事件特征工程

滑动窗口特征 · Session窗口特征 · 计数与比率特征

实时特征存储

Redis vs Aerospike · 特征更新策略与过期机制

规则引擎设计

规则模型定义 · 规则编译与执行 · 规则热更新

决策树模型实战

ID3/C4.5算法 · 特征选择 · 剪枝策略

随机森林与集成学习

Bagging思想 · 特征随机性 · 模型融合

集成随机森林

XGBoost模型实战

梯度提升原理 · 参数调优 · 特征重要性

XGBoostBoosting

深度学习模型

DNN结构设计 · Embedding层 · 实时推理优化

模型在线部署

TF Serving · ONNX Runtime · 模型版本管理

模型监控与漂移检测

PSI指标 · 数据漂移 · 概念漂移

实时特征计算引擎

Flink SQL vs ProcessFunction · 性能对比

Flink SQL性能

事件回溯与回测

离线回测框架 · 时间旅行 · 结果评估

回测时间旅行

风控策略编排

策略流程图 · 条件节点 · 动作节点 · 并行执行

黑白名单系统

布隆过滤器 · Redis Set · 实时查询优化

布隆黑名单

频率控制与限流

滑动窗口限流 · 令牌桶算法 · 分布式限流

限流令牌桶

设备指纹技术

浏览器指纹 · 设备ID生成 · 关联分析

关联网络分析

图数据库选型 · 社群发现 · 团伙识别

实时指标计算

Count/Min/Max/Avg · HyperLogLog · TopN

事件序列模式挖掘

PrefixSpan算法 · 频繁序列模式 · 行为路径分析

序列PrefixSpan

A/B测试框架

分流策略 · 实验分组 · 效果评估

风控系统高可用

多活架构 · 降级策略 · 熔断机制

高可用熔断

实时数据血缘

事件溯源 · 链路追踪 · 数据质量监控

端到端实战项目

从埋点到决策 · 完整风控系统搭建