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

低延迟额度策略：流式决策链路搭建指南

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论
低延迟额度策略的定义 · 业务价值（如实时授信 · 反欺诈）
课程导论低延迟额度策略的…
02
流式决策核心概念
事件驱动 · 有状态计算 · Exactly-Once语义
流式决策核心概念事件驱动
03
技术选型对比
Flink vs Spark Str… · 吞吐 · 状态管理能力对比
技术选型对比Flink
04
架构总览
端到端流式额度决策链路图（数据接入…
架构总览端到端流式额度决…
05
数据源接入
实时接入用户行为日志 · 交易流水 · 外部征信API回调
数据源接入实时接入用户行为…
06
事件时间与处理时间
在额度策略中如何选择时间语义 · 处理乱序事件与延迟数据（Waterm…
事件时间处理时间
07
实时特征工程（上）
滑动窗口统计（近5分钟交易次数 · 金额总和） · 会话窗口（用户浏览行为聚合）
实时特征工程滑动窗口统计
08
实时特征工程（下）
CEP复杂事件处理（识别短时间多设备… · 频繁修改个人信息等风险模式）
实时特征工程CEP
09
状态后端选型
RocksDB vs HashMap… · 状态TTL设置 · 大状态对延迟的影响及优化
状态后端选型RocksDB
10
规则引擎集成
将Drools/Aviator/自研… · 实现毫秒级规则匹配
规则引擎集成Drools/Aviat…
11
模型推理服务化
通过gRPC/REST调用远程模型服… · 深度学习模型） · 处理超时与降级
模型推理服务化gRPC/REST
12
模型推理本地化
使用PMML/ONNX/Tensor… · 消除网络开销
模型推理本地化PMML/ONNX/Te…
13
额度计算逻辑
基于特征与模型分数 · 结合用户分层 · 产品限额
额度计算逻辑基于特征
14
异步I/O优化
使用Flink AsyncIO并发调… · HBase）或模型服务 · 避免算子阻塞
I/O异步
15
内存管理与调优
堆外内存配置 · Managed Memory调优 · 避免Full GC导致的延迟抖动
内存管理调优
16
序列化与网络优化
使用Kryo/Pojo序列化 · 调整Buffer超时时间（buffe…
序列化网络优化
17
Checkpoint与状态一致性
轻量级Checkpoint配置（增量… · 最小间隔） · 在保证一致性的同时降低对延迟的影响
Checkpoint状态一致性
18
端到端延迟监控
定义P99/P999延迟指标 · 使用Prometheus + Gra… · 背压
端到端延迟监控P99/P999
19
全链路压测
使用JMeter/Gatling模拟… · 定位瓶颈（CPU · IO
全链路压测JMeter/Gatli…
20
动态策略更新
通过广播流（Broadcast St… · 模型 · 额度的热更新
动态策略更新Broadcast
21
多级缓存设计
本地缓存（Caffeine）+ 分布… · 减少外部依赖
多级缓存设计Caffeine
22
降级与熔断机制
当模型服务或外部数据源超时时 · 自动降级为备用规则或静态额度 · 保障系统可用性
降级熔断机制
23
灰度发布与A/B测试
在流式链路中分流 · 对不同用户群体应用不同策略版本 · 实时对比效果
A/B灰度发布
24
数据倾斜处理
KeyBy热点用户导致的反压 · 使用Salting · Local-Global聚合等方案解…
数据倾斜处理KeyBy
25
资源动态扩缩容
基于Kubernetes + Fli… · 根据背压指标自动调整并行度
资源动态扩缩容Kubernetes
26
安全与审计
实时决策日志的完整链路追踪（Trac… · 确保决策可回溯 · 满足合规要求
安全审计
27
案例实战（一）
搭建一个简单的实时额度审批Demo · 包含数据生成 · 特征计算
案例实战Demo
28
案例实战（二）
集成外部模型服务 · 实现基于模型分数的动态额度 · 并展示延迟指标
案例实战集成外部模型服务
29
案例实战（三）
实现策略热更新与降级 · 模拟模型服务故障 · 观察系统自动切换至降级规则
案例实战实现策略热更新
30
课程总结与展望
低延迟额度策略的最佳实践总结 · 未来趋势（如流式机器学习 · 联邦学习在风控中的应用）
课程总结低延迟额度策略的…