VIP10
本课程属于：037-Kafka与Flink金融实时数据工程 智能金融与金融工程 · 共 10 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

金融实时数据管道端到端项目实战

共计 30 章节
可可资料掘金营 · 点击在线试看
01
课程导入
目标=金融实时数据管道的定义 · 学习目标 · 整体架构与端到端项目全景
课程导入目标=金融实时数…
02
金融数据基础
目标=行情数据 · 交易数据 · 基本面数据
金融数据基础目标=行情数据
03
实时数据管道核心概念
目标=流处理 · 批处理 · 消息队列
实时数据管道核心…目标=流处理
04
技术选型与架构设计
目标=Kafka · Pulsar · Flink
技术选型架构设计
05
数据采集层实战
目标=从交易所 API · 行情网关 · 数据库 CDC 实时采集金融数据并接…
数据采集层实战API
06
消息队列深入
目标=Kafka 主题 · 分区 · 副本
消息队列深入Kafka
07
流处理引擎入门
目标=Flink 核心概念 · DataStream API · 事件时间处理与状态管理
流处理引擎入门Flink
08
流处理进阶
目标=Flink 窗口计算 · 水位线机制 · 迟到数据处理与 Exactly-On…
流处理进阶Flink
09
数据清洗与转换
目标=实时数据去重 · 格式标准化 · 字段映射
数据清洗转换
10
实时指标计算
目标=VWAP · TWAP · 成交量
实时指标计算VWAP
11
复杂事件处理
目标=模式匹配 · 序列检测 · 异常交易行为识别与实时告警
复杂事件处理目标=模式匹配
12
数据存储与查询
目标=实时写入 ClickHouse · Druid · Redis 等存储并支持低延迟查询
数据存储查询
13
数据服务层
目标=实时数据 API 设计 · WebSocket 推送 · 订阅分发与多租户隔离
数据服务层API
14
监控与运维
目标=管道健康检查 · 延迟监控 · 吞吐量监控
监控运维
15
容错与高可用
目标=故障转移 · 数据重放 · 背压处理
容错高可用
16
性能优化
目标=并行度调优 · 资源分配 · 序列化优化
性能优化目标=并行度调优
17
安全与合规
目标=数据加密 · 访问控制 · 审计日志
安全合规
18
实战项目一
目标=搭建实时行情数据管道 · 从数据源到 Kafka 再到 Fli…
实战项目一目标=搭建实时行…
19
实战项目二
目标=构建实时交易监控管道 · 检测异常交易并触发实时告警
实战项目二目标=构建实时交…
20
实战项目三
目标=实现实时风控数据管道 · 计算风险指标并推送至风控决策引擎
实战项目三目标=实现实时风…
21
实战项目四
目标=端到端回测与模拟
实战项目四目标=端到端回测
22
常见问题与排查
目标=数据丢失 · 重复消费 · 延迟高
常见问题排查
23
测试策略
目标=单元测试 · 集成测试 · 端到端测试
测试策略目标=单元测试
24
部署与发布
目标=容器化 · Kubernetes 编排 · CI/CD 流水线与灰度发布
部署发布
25
云原生与混合云
目标=在 AWS · GCP · 阿里云上部署金融实时数据管道的实践与…
云原生混合云
26
数据治理
目标=元数据管理 · 数据血缘 · 数据版本控制与实时数据质量度量
数据治理目标=元数据管理
27
机器学习集成
目标=实时特征工程 · 在线推理与模型更新在金融管道中的落地
机器学习集成目标=实时特征工…
28
综合案例
目标=从零构建一个完整的金融实时数据… · 涵盖采集 · 处理
综合案例目标=从零构建一…
29
项目复盘与优化
目标=分析项目瓶颈 · 总结最佳实践 · 制定持续改进路线图
项目复盘优化
30
课程总结与进阶
目标=知识体系回顾 · 职业发展建议 · 前沿技术趋势与学习资源推荐
课程总结进阶