数据管道通过多个步骤完成采集与转换：流处理持续处理不断到达的数据事件

数据管道通过多个步骤完成采集与转换。抽取转换加载先加工再写入目标存储。抽取加载转换先保留数据再执行加工。数据湖保存多种结构和格式的原始数据。数据仓库面向分析组织较稳定的数据模型。湖仓方案尝试结合开放存储与表管理能力。列式存储适合读取少量列的大规模分析。行式存储适合部分面向完整记录的访问。

数据工程组织数据的获取与加工和交付。数据源可能来自业务系统或外部采集。批处理按照时间或数据规模集中执行任务。流处理持续处理不断到达的数据事件。事件时间对应现实业务事件发生的时刻。处理时间对应系统实际执行计算的时刻。乱序事件可能晚于其业务发生顺序到达。水位线用于表达事件时间处理的进展估计。

分区裁剪通过过滤条件减少实际读取范围。小文件过多可能增加元数据和调度开销。文件合并用于改善过度碎片化的数据布局。数据压缩降低存储和传输但需要解码计算。模式演化管理字段增加和类型变化等问题。数据契约明确生产方与使用方的格式约定。数据质量包含完整性与一致性等维度。缺失记录可能来自采集失败或业务规则。

增量处理只计算新到达或发生变化的内容。变更数据捕获从源系统提取增删改事件。删除事件也需要传递到下游副本和缓存。回填重新处理历史数据以修正或补充结果。回填任务需要避免压垮正常在线处理。数据脱敏降低直接暴露敏感信息的风险。匿名化效果需要考虑多字段组合识别可能。数据保留策略明确保存期限和清理责任。数据工程结果需要能够解释和追溯来源。