ARTICLE · INTELLIGENCE

战地情报 · 详情页

来自尧图项目组的一线实战观察与深度解析

Spark 读取 S3 上损坏 gzip 文件时跳过异常文件并记录

Spark 读取 S3 上损坏 gzip 文件时跳过异常文件并记录

每天从 S3 拉取几千个 gzip 压缩的 JSON 文件,绝大多数时候一切正常,但只要其中有一两个文件损坏,整次load()就失败。这类偶发脏文件很难从源头杜绝,更务实的做法是让主链路容错,同时把异常文件单独记录下来。

问题现象

读取代码本身再普通不过:

defread_data(spark:SparkSession)->DataFrame:spark_reader=spark.read.format(
RELATED READING

延伸阅读

更多一线实战笔记与深度复盘,助您持续精进