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

从0搭建信用额度定价流式决策链路教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论与目标
信用额度定价的业务背景 · 流式决策与传统批处理的区别 · 课程整体架构与学习路径
课程导论目标
02
核心概念解析
信用评分 · 风险定价 · 额度管理
核心概念解析信用评分
03
技术栈选型
流式计算框架（Flink/Spark… · 规则引擎（Drools/EasyRu… · 数据库（Redis/MySQL）
技术栈选型Flink/Spark
04
环境搭建
JDK · Maven · Git
环境搭建JDK
05
数据模型设计
用户画像表 · 订单表 · 额度表
数据模型设计用户画像表
06
消息队列搭建
Kafka单机/集群安装 · Topic创建 · 生产者与消费者基础API使用
消息队列搭建Kafka
07
流式数据接入
使用Flink读取Kafka中的用户… · 进行反序列化与初步清洗
流式数据接入Flink
08
特征工程（实时侧）
基于滑动窗口计算用户近30天消费频次 · 逾期次数 · 额度使用率等实时特征
特征工程实时侧
09
规则引擎集成
在Flink中集成Drools · 加载DRL规则文件 · 实现“是否准入”的硬规则过滤
规则引擎集成Flink
10
额度定价模型（一）
基于逻辑回归的初始额度预估模型 · 模型训练（Python）与PMML导…
额度定价模型基于逻辑回归的初…
11
额度定价模型（二）
在Flink中加载PMML模型 · 对通过规则的用户进行实时额度打分
额度定价模型Flink
12
利率与期限定价
基于用户风险等级动态计算年化利率与还… · 输出定价方案
利率期限定价
13
额度缓存策略
使用Redis缓存用户最新额度与定价… · 减少重复计算 · 提升吞吐
额度缓存策略Redis
14
决策结果回写
将最终额度 · 利率 · 有效期等结果写入MySQL订单表
决策结果回写将最终额度
15
异常处理与降级
流式处理中的脏数据过滤 · 模型加载失败降级策略 · Kafka消费偏移量管理
异常处理降级
16
单元测试与集成测试
使用JUnit + Flink Mi… · Mock Kafka与Redis
单元测试集成测试
17
性能压测
使用JMeter或Flink自带的压… · 模拟高并发事件流 · 观察延迟与吞吐
性能压测JMeter
18
监控与告警
集成Prometheus + Gra… · 监控Flink作业的延迟 · 吞吐
监控告警
19
日志链路追踪
使用SLF4J + MDC实现全链路… · 方便排查单笔决策日志
日志链路追踪SLF4J
20
灰度发布与AB测试
设计双跑策略 · 新模型与旧模型同时决策 · 对比效果后切换
AB灰度发布
21
版本管理与回滚
规则文件与模型文件的版本控制（Git… · 一键回滚机制
版本管理回滚
22
安全与合规
用户数据脱敏 · 决策日志脱敏 · GDPR/个人信息保护法合规要点
安全合规
23
多租户支持
设计租户隔离的额度定价策略 · 不同业务线使用不同的规则与模型
多租户支持设计租户隔离的额…
24
实时特征存储
使用Redis或HBase存储用户实… · 支持跨会话决策
实时特征存储Redis
25
外部数据源接入
通过异步RPC调用征信机构 · 黑名单库 · 并处理超时与熔断
外部数据源接入RPC
26
决策链路可视化
使用D3.js或ECharts绘制单…
决策链路可视化D3.js
27
全链路压测方案
从Kafka生产端到Flink消费端… · 模拟真实流量
全链路压测方案Kafka
28
生产部署
Flink On YARN/K8s部… · Kafka集群高可用配置 · MySQL读写分离
生产部署Flink
29
运维手册
常见问题排查（背压 · OOM · 数据倾斜）
运维手册常见问题排查
30
课程总结与展望
回顾流式决策链路的关键设计 · 展望AI驱动的动态定价与联邦学习
课程总结回顾流式决策链路…