每天从 S3 拉取几千个 gzip 压缩的 JSON 文件,绝大多数时候一切正常,但只要其中有一两个文件损坏,整次load()就失败。这类偶发脏文件很难从源头杜绝,更务实的做法是让主链路容错,同时把异常文件单独记录下来。
问题现象
读取代码本身再普通不过:
defread_data(spark:SparkSession)->DataFrame:spark_reader=spark.read.format(来自尧图项目组的一线实战观察与深度解析
每天从 S3 拉取几千个 gzip 压缩的 JSON 文件,绝大多数时候一切正常,但只要其中有一两个文件损坏,整次load()就失败。这类偶发脏文件很难从源头杜绝,更务实的做法是让主链路容错,同时把异常文件单独记录下来。
读取代码本身再普通不过:
defread_data(spark:SparkSession)->DataFrame:spark_reader=spark.read.format(更多一线实战笔记与深度复盘,助您持续精进