首页/数据/数据工程与 ETL 速查/数据管道的组成环节
管道基础52 条

数据管道的组成环节

一条管道通常包含采集、传输、处理、存储、服务五个环节,另有调度、质量、监控三条支撑线。按环节拆分能快速定位延迟与故障出在哪一段。

采集从库、日志、API 拉取或接收数据
传输Kafka 等消息队列或对象存储落地
处理批/流引擎完成清洗、关联与聚合
服务结果写入查询引擎或在线数据库

典型链路示意

典型链路示意
源库/日志 → 采集(CDC/Agent)→ 消息队列 → 处理(批/流)→ 存储(数仓/湖)→ 服务(BI/接口)
支撑线:调度(依赖与重跑)、质量(校验与告警)、监控(延迟与积压)
  • 链路上任何一段断掉,端到端新鲜度都会退化
  • 排障先分段:源端 → 采集 → 传输 → 加工 → 服务,逐段看指标
为每段链路定义可观测指标(延迟、积压、成功率),是数据链路值班的基础。

易错点

  • 只监控最终任务而不监控中间积压,故障时无法判断瓶颈在哪一段
  • 跨环节的字段类型/schema 约定不清,会在加工段集中爆错

数据来源与参考

  • 《数据密集型应用系统设计》(Martin Kleppmann)数据系统章节
  • Apache Kafka 官方文档:Data Integration 场景
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌