VIP20
本课程属于：087-实时风控网关特征缺失巡检 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

风险网关特征缺失巡检与Flink应用

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
风险网关概述
风险网关的定义 · 在风控体系中的位置 · 核心功能与价值
风险网关概述风险网关的定义
02
特征缺失问题
特征缺失的定义 · 常见原因（数据源故障 · ETL延迟
特征缺失问题特征缺失的定义
03
巡检系统设计原则
巡检的实时性 · 准确性 · 低延迟
巡检系统设计原则巡检的实时性
04
Flink基础回顾
Flink的流处理模型 · DataStream API · 时间语义
Flink基础回顾
05
Flink状态后端
状态的概念 · 状态后端类型（Memory/File… · 状态TTL配置
Flink状态后端
06
特征缺失巡检数据源
Kafka作为特征事件流 · 特征元数据管理表（MySQL/HBa… · 数据接入设计
特征缺失巡检数据…Kafka
07
特征事件模型定义
定义特征事件Java POJO（特征… · 时间戳 · 特征值
特征事件模型定义Java
08
Flink Source连接器
Kafka Consumer配置 · 反序列化Schema · 起始消费位置策略
FlinkSource
09
特征缺失检测核心逻辑
基于窗口（Tumbling/ Sli… · 缺失次数 · 连续缺失次数
特征缺失检测核心…Tumbling
10
CEP复杂事件处理
使用Flink CEP定义缺失模式（… · Pattern API详解
CEP复杂事件处理
11
动态规则配置
将巡检阈值（如缺失率>5%）存储在外… · Flink广播流动态更新规则
动态规则配置将巡检阈值
12
广播状态模式
BroadcastStream与Ke… · BroadcastState的读写 · 规则热更新实现
广播状态模式BroadcastStr…
13
特征缺失分级告警
根据缺失严重程度（轻微/严重/致命）… · 输出不同告警通道
特征缺失分级告警根据缺失严重程度
14
告警输出Sink
告警结果写入Kafka（告警事件流） · 写入MySQL（告警记录表） · 写入Elasticsearch（告警…
Sink告警输出
15
Flink SQL实现巡检
使用Flink SQL定义CREAT… · INSERT INTO SELECT… · 简化开发
FlinkSQL
16
维表关联
特征元数据维表（MySQL/HBas… · 使用AsyncIO或LookupJo…
维表关联MySQL/HBas
17
多维度聚合
按网关ID · 特征类型 · 时间窗口进行多维聚合
多维度聚合ID
18
延迟数据处理
处理迟到特征事件 · 使用AllowedLateness与… · 避免影响窗口结果
延迟数据处理处理迟到特征事件
19
Checkpoint与容错
Checkpoint配置（间隔 · 模式） · Exactly-Once语义保证
Checkpoint容错
20
Savepoint与版本升级
Savepoint手动触发 · Flink任务升级（修改逻辑/并行度…
Savepoint版本升级
21
性能优化
并行度设置 · KeyBy优化 · 状态大小控制
性能优化并行度设置
22
监控与告警体系
Flink Metrics（延迟 · 吞吐量 · 状态大小）
监控告警体系
23
特征缺失数据回溯
对于历史缺失数据 · 使用Flink批处理模式或DataS…
特征缺失数据回溯对于历史缺失数据
24
数据质量SLA
定义特征缺失SLA指标（如 · 巡检结果与SLA对比 · 生成SLA报告
SLA数据质量
25
多机房/异地多活部署
Flink任务跨机房部署 · Kafka跨机房复制 · 特征数据一致性保障
多机房异地多活部署
26
灰度发布与A/B测试
新巡检规则灰度上线 · 使用Flink的SideOutput… · 对比新旧规则效果
A/B灰度发布
27
特征血缘与影响分析
记录特征缺失事件的血缘关系 · 结合元数据系统分析缺失对下游模型/策…
特征血缘影响分析
28
实战案例一
支付风控网关特征缺失巡检：从需求分析 · 数据流设计 · Flink作业开发到上线全流程
实战案例一支付风控网关特征…
29
实战案例二
信贷审批网关特征缺失巡检 · 复杂规则配置 · 高并发场景下的稳定性保障
实战案例二信贷审批网关特征…
30
课程总结与展望
特征缺失巡检最佳实践总结 · Flink未来发展方向（Flink… · 流批一体）
课程总结特征缺失巡检最佳…