非常游戏网
如何优雅地捕获并处理 pandas.concat 的异常以继续执行程序

如何优雅地捕获并处理 pandas.concat 的异常以继续执行程序

2026-05-27日常编程142571

本文介绍在使用 pandas 读取多个 csv 文件并合并时,如何正确捕获空文件等导致的异常,避免程序中断,同时保留日志反馈和流程可控性。

本文介绍在使用 pandas 读取多个 csv 文件并合并时,如何正确捕获空文件等导致的异常,避免程序中断,同时保留日志反馈和流程可控性。

在批量处理 CSV 元数据文件(如 metadata_files 列表)时,常见问题包括:文件为空、格式损坏、编码不兼容或列结构不一致。此时 pd.concat() 可能抛出 ValueError(如“No objects to concatenate”)、EmptyDataError 或 ParserError,直接导致程序终止。仅用裸 except: 捕获所有异常虽可“续跑”,但缺乏健壮性和可观测性。

✅ 推荐做法:精准捕获 + 有状态跳过 + 可追溯日志

以下是一个生产就绪的改进方案:

import pandas as pd
from pandas.errors import EmptyDataError, ParserError

metadata_files = ["meta1.csv", "meta2.csv", "empty.csv"]  # 示例路径
valid_dfs = []

for file in metadata_files:
    try:
        df = pd.read_csv(file, encoding='utf-8', sep=";")
        if df.empty:
            print(f"⚠️  警告:跳过空文件 '{file}'")
            continue
        valid_dfs.append(df)
    except EmptyDataError:
        print(f"❌ 错误:文件 '{file}' 为空或无有效数据行")
    except ParserError as e:
        print(f"❌ 解析错误:'{file}' — {str(e).split('.')[0]}")
    except UnicodeDecodeError as e:
        print(f"❌ 编码错误:'{file}' — 请检查编码格式(当前使用 utf-8)")
    except Exception as e:
        print(f"❌ 未预期错误:'{file}' — {type(e).__name__}: {e}")

# 安全合并:仅当至少有一个有效 DataFrame 时才 concat
if valid_dfs:
    meta_files_df = pd.concat(valid_dfs, ignore_index=True, sort=False)
    print(f"✅ 成功合并 {len(valid_dfs)} 个文件,总计 {len(meta_files_df)} 行数据")
else:
    print("⚠️  警告:无有效数据可合并,返回空 DataFrame")
    meta_files_df = pd.DataFrame()  # 显式初始化,确保变量始终存在

? 关键改进说明:

  • 不依赖生成器 + pd.concat 一次性调用:原代码中 (pd.read_csv(...) for file in ...) 是惰性生成器,一旦 concat 报错,已成功读取的中间 DataFrame 将丢失且无法定位具体失败文件。改用显式循环可逐个控制、记录与恢复。
  • 精准异常类型捕获:区分 EmptyDataError(pandas 专用)、ParserError(CSV 格式问题)、UnicodeDecodeError(编码问题),便于针对性修复。
  • 空数据显式检查:read_csv 可能返回空 DataFrame(非异常),需手动 if df.empty 判断并跳过,防止后续 concat 因空列表报错。
  • 变量始终可访问:无论是否成功合并,meta_files_df 均被定义(空或有效),避免 NameError,提升下游代码健壮性。
  • 日志含上下文:每条消息包含文件名和简明原因,支持快速排查;使用 emoji 提升可读性(生产环境可替换为标准前缀如 [WARN]/[ERROR])。

? 进阶建议:

  • 将日志输出接入 logging 模块,支持级别控制与文件持久化;
  • 对关键失败文件记录到 failed_files.log,供人工复核;
  • 使用 pathlib.Path(file).stat().st_size > 0 在读取前预判空文件,减少 I/O 开销。

通过以上结构化异常处理,程序不再因单个坏文件而中断,同时保持高度可观测性与可维护性——这才是真正面向生产的容错实践。