首页/数据/数据工程与 ETL 速查/对象存储作为数据落地区
管道基础52 条

对象存储作为数据落地区

数据湖常以对象存储作为落地区:S3/OSS 等提供廉价容量,Hadoop 生态通过 s3a:// 等 scheme 访问;注意其最终一致性已改善但目录操作语义与本地文件系统不同。

路径 schemes3a://(Hadoop 常用)、oss://、cos:// 依发行版而定
分层约定landing(原始)→ curated(清洗)→ marts(应用)
访问工具spark/hadoop fs、各云厂商 CLI/SDK

用 hadoop fs 查看分区目录

用 hadoop fs 查看分区目录
hadoop fs -ls s3a://lake/curated/dwd/orders/dt=2026-10-11/ | head
hadoop fs -cat s3a://lake/curated/dwd/orders/dt=2026-10-11/_SUCCESS
对象存储的 rename 是拷贝加删除、并非原子操作;依赖“临时目录 rename 落地”的流程要改为清单文件或提交协议标记完成。

易错点

  • 大目录 LIST 操作成本高,避免每次任务全量列举目录来判断新文件
  • 写入方与读取方跨账号/跨区域访问配置不全时,报错信息常指向权限而非网络

数据来源与参考

  • AWS 官方文档:Amazon S3 Consistency Model
  • Hadoop 官方文档:S3A 文件系统语义
​‌‌​​‌​​​‌‌​‌‌‌‌​‌‌​​​‌‌​‌‌‌​​‌‌​​‌​‌‌‌​​‌‌‌​​​‌​‌‌​‌​​‌​‌‌‌​​​‌​‌‌​‌​​‌​‌‌​​​‌‌​‌‌‌​‌​​​‌‌​‌‌‌‌​​‌​‌‌‌​​‌‌​​​‌‌​‌‌​‌‌‌‌​‌‌​‌‌​‌