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

Flink低延迟风控特征巡检教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导学与风控背景
风控特征巡检的业务价值 · 低延迟场景定义 · 课程目标与前置知识
课程导学风控背景
02
Flink核心概念速览
DataStream · 时间语义 · 窗口
Flink核心概念速览
03
风控特征体系概述
特征分类（实时/离线） · 特征生命周期 · 特征巡检的核心指标（延迟
风控特征体系概述特征分类
04
开发环境搭建
JDK · Maven · Flink集群（Standalone…
开发环境搭建JDK
05
第一个Flink风控作业
从Kafka读取交易事件流 · 简单过滤 · 打印输出
Flink第一个
06
事件时间与水位线
EventTime vs Proce… · Watermark生成策略 · 处理乱序数据
事件时间水位线
07
状态编程基础
KeyedState（ValueSt… · 状态后端（RocksDB/Heap） · 状态TTL
状态编程基础KeyedState
08
ProcessFunction实战
KeyedProcessFuncti… · 定时器（Timer） · 实现特征值累加与过期清理
ProcessFunct…KeyedProcess…
09
风控特征计算——滑动窗口聚合
Tumbling/Sliding W… · 计算过去5分钟交易总额 · 窗口状态优化
风控特征计算滑动窗口聚合
10
风控特征计算——CEP复杂事件处理
Flink CEP API · 定义风险模式（如短时间高频交易） · 匹配输出
CEP风控特征计算
11
维表关联与异步IO
维表（Redis/MySQL）实时关… · AsyncIO实现低延迟查询 · 缓存策略
IO维表关联
12
动态规则引擎
规则配置化（Flink广播流） · 规则变更热更新 · 规则匹配与特征输出
动态规则引擎Flink
13
特征存储与输出
Sink到Kafka/Redis/C… · 序列化（Avro/JSON） · Exactly-Once语义保证
特征存储输出
14
延迟监控与告警
自定义延迟度量（LatencyMar… · Prometheus+Grafana… · 告警规则配置
延迟监控告警
15
特征巡检任务——数据质量校验
空值检测 · 异常值过滤 · 特征分布统计
特征巡检任务数据质量校验
16
特征巡检任务——特征时效性检查
特征新鲜度计算 · 过期特征标记 · 延迟特征回补机制
特征巡检任务特征时效性检查
17
特征巡检任务——特征一致性比对
实时特征 vs 离线特征交叉验证 · 偏差告警 · 修复流程
特征巡检任务特征一致性比对
18
多流Join与关联
双流Join（Interval Jo… · 多流合并 · 关联延迟优化
Join多流
19
状态后端调优
RocksDB参数调优（内存/线程/… · 增量Checkpoint · 大状态性能优化
状态后端调优RocksDB
20
内存管理与反压处理
Flink内存模型 · 网络缓冲 · 反压检测与定位
内存管理反压处理
21
作业调优与并行度设置
算子链 · 并行度推导 · 资源分配
作业调优并行度设置
22
容错与恢复机制
Checkpoint配置 · Exactly-Once语义 · 故障恢复策略（RestartStra…
容错恢复机制
23
生产环境部署
Flink on YARN/K8s部… · 高可用配置（ZooKeeper） · 日志与监控集成
生产环境部署Flink
24
Flink SQL在风控中的应用
动态表 · 窗口聚合 · 维表Join
FlinkSQL
25
PyFlink风控特征开发
Python UDF · PyFlink DataStream… · 与Java作业混合部署
PyFlink风控特征开发
26
特征巡检平台架构设计
整体架构图（采集层/计算层/存储层/… · 模块职责 · 技术选型
特征巡检平台架构…整体架构图
27
端到端延迟压测
压测工具（JMeter/自研） · 延迟分布分析 · P99/P999优化
端到端延迟压测JMeter
28
案例实战——实时反欺诈特征巡检
需求分析 · 特征设计 · 作业开发
案例实战实时反欺诈特征巡…
29
案例实战——实时信用评分特征巡检
评分模型特征计算 · 特征漂移检测 · 模型回滚机制
案例实战实时信用评分特征…
30
课程总结与进阶方向
核心知识回顾 · 常见坑点总结 · 推荐学习资源
课程总结进阶方向