VIP20
本课程属于：015-保险精算模型坏样本归因 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

精算坏样本归因Flink实时处理教程

共计 30 章节
点击此处阅读海量试读课程：100+行业、1000+细分领域
01
课程导论与背景
精算坏样本定义 · 归因分析在保险风控中的价值 · 实时处理与传统批处理的对比
课程导论背景
02
Flink基础与环境搭建
Flink核心概念（DataStre… · Operator · Time）
Flink环境搭建
03
精算数据模型设计
保单维度 · 理赔维度 · 客户维度的关键字段定义
精算数据模型设计保单维度
04
Flink DataStream API入门
Source（Kafka · 文件） · Transformation（map
FlinkDataStream
05
事件时间与水位线
Event Time · Processing Time · Ingestion Time的区别
事件时间水位线
06
坏样本特征工程（实时侧）
滑动窗口聚合（赔付金额 · 出险次数） · 特征归一化
坏样本特征工程实时侧
07
Flink SQL在精算归因中的应用
CREATE TABLE语句 · Group By窗口 · TUMBLE/HOP窗口聚合坏样本指…
FlinkSQL
08
状态后端与精确一次语义
ValueState · MapState存储客户历史赔付画像 · Checkpoint与Savepoi…
状态后端精确一次语义
09
实时规则引擎集成
将精算归因规则（如“3个月内出险>2…
实时规则引擎集成将精算归因规则
10
多维下钻分析
按险种 · 地区 · 渠道维度实时统计坏样本占比
多维下钻分析按险种
11
Flink与Kafka深度集成
Kafka Topic分区策略 · Consumer Offset管理 · 反压监控与背压处理
FlinkKafka
12
动态规则更新
通过广播流（BroadcastStr… · 无需重启作业
动态规则更新BroadcastStr
13
复杂事件处理（CEP）
定义坏样本序列模式（如“报案→定损→… · 输出预警信号
CEP复杂事件处理
14
实时特征存储
使用Flink与Redis/HBas… · 存储客户实时特征向量 · 供模型推理使用
实时特征存储Flink
15
模型推理集成
在Flink中调用PMML/ONNX… · 对实时特征进行坏样本概率预测
模型推理集成Flink
16
归因结果可视化
将Flink输出结果写入Elasti… · 通过Kibana构建实时归因看板
归因结果可视化Flink
17
性能调优
并行度设置 · 算子链优化 · 数据倾斜处理
性能调优并行度设置
18
容错与恢复
基于Savepoint的作业升级 · Exactly-Once语义在精算场…
容错恢复
19
实时数据质量监控
监控输入数据延迟 · 字段缺失率 · 坏样本标签异常波动
实时数据质量监控监控输入数据延迟
20
多源数据关联
将Flink与维表（MySQL保单表 · HBase黑名单）进行异步IO关联 · 丰富归因上下文
多源数据关联Flink
21
时间序列异常检测
基于Flink的滑动窗口计算赔付率Z… · 识别突发性坏样本聚集
时间序列异常检测Flink
22
AB实验与归因效果评估
在Flink中分流实验组/对照组 · 实时计算归因准确率与召回率
AB实验
23
Flink ML Pipeline
使用Flink ML进行在线聚类（如…
FlinkML
24
数据湖集成
将归因中间结果写入Iceberg/H… · 支持批流一体查询
数据湖集成Iceberg/H
25
安全与权限控制
Flink作业的RBAC · 敏感字段脱敏（如身份证号） · 审计日志
安全权限控制
26
生产环境部署
Flink on YARN/K8s部… · 资源配额 · 日志采集（ELK）
生产环境部署Flink
27
监控与告警体系
Prometheus + Grafa… · 吞吐量 · Checkpoint失败率
监控告警体系
28
案例实战一
车险高频出险客户实时归因 · 从Kafka消费到归因结果写入MyS…
案例实战一车险高频出险客户…
29
案例实战二
健康险欺诈团伙实时识别 · 基于CEP模式匹配与图关联
案例实战二健康险欺诈团伙实…
30
课程总结与最佳实践
常见坑点 · 架构演进建议 · 后续学习路径（Flink + AI融…
课程总结最佳实践