基于事件触发批量加载CSV文件至BigQuery表失败，请求排查代码问题

首先看你的代码里有一个明显的语法错误，这会直接导致执行失败：在调用client.load_table_from_uri的时候，你缺少了闭合的右括号。原代码这段：

load_job = client.load_table_from_uri(
    uri, dataset_ref.table(os.environ['TABLE'])
load_job.result() # wait for table load to complete.

应该修正为：

load_job = client.load_table_from_uri(
    uri, dataset_ref.table(os.environ['TABLE'])
)  # 补上这个右括号
load_job.result() # wait for table load to complete.

接下来是你提到的「单个文件指定Schema能跑，多文件加载报错」的核心问题，主要有两个关键点：

1. 缺少显式Schema导致自动推断失败 #

当你加载多个CSV时，如果没有在LoadJobConfig里指定固定Schema，BigQuery会默认从第一个加载的文件推断Schema。但如果后续文件的结构（比如列数、数据类型、表头顺序）和第一个文件不一致，就会触发加载错误。而单个文件时你指定了Schema，匹配了该文件的结构，所以能正常运行。

解决方法：在job_config里显式定义Schema，确保所有CSV文件的结构和这个Schema完全匹配：

job_config = bigquery.LoadJobConfig(
    source_format=bigquery.SourceFormat.CSV,
    field_delimiter="|",
    write_disposition="WRITE_TRUNCATE",
    skip_leading_rows=1,
    # 按你的实际表结构添加Schema字段
    schema=[
        bigquery.SchemaField("user_id", "STRING"),
        bigquery.SchemaField("order_amount", "FLOAT"),
        bigquery.SchemaField("order_date", "DATE"),
        # 依次添加所有列
    ]
)

2. 多文件触发时的写入策略问题 #

你的代码里用了WRITE_TRUNCATE，这个策略会在每次加载时清空目标表再写入当前文件的数据。如果你的Cloud Function是每个CSV文件上传时触发一次，那么最后你的表只会保留最后一个上传文件的数据，而不是所有文件的合并结果。

如果需要合并所有CSV的数据到同一个表，建议：

• 把写入策略改成WRITE_APPEND，这样每次加载都会把当前文件的数据追加到表中；
• 或者修改触发逻辑，当多个文件上传完成后，一次性收集所有文件的URI，用client.load_table_from_uri加载多个URI（可以传一个URI列表，比如["gs://bucket/file1.csv", "gs://bucket/file2.csv"]），这样能更高效地批量加载。

额外检查项 #

• 确认所有CSV文件的分隔符都是|，没有文件用了其他分隔符；
• 检查所有文件的表头行数一致，都是1行（你的代码设置了skip_leading_rows=1）；
• 确保没有空文件或者格式损坏的CSV文件，这类文件会导致加载失败。

内容的提问来源于stack exchange，提问作者exploding_data