os.Create生成CSV后上传BigQuery无数据，读取已有文件正常是什么原因？

根因说明 #

你遇到的问题由两个逻辑漏洞共同导致：

• csv 缓冲区未提前刷入文件：你使用defer writer.Flush()，而defer语句会在整个Do函数退出时才执行。调用bqClient.LoadCsv时，所有写入的csv数据仍停留在csv.Writer的内存缓冲区，既没有写入操作系统文件缓冲区，也没有落盘。
• 文件读写指针未复位：即使提前刷入缓冲，写完内容后文件的读写指针默认停在文件末尾位置，直接将file对象传入bigquery.NewReaderSource时，会从指针当前位置（文件末尾）往后读取，自然拿不到任何数据。这也是你改用os.Open读取已有文件可以正常运行的原因：打开已有文件时指针默认在文件开头。

修复方案 #

在写完csv内容、加载到BigQuery之前，新增两步操作即可：

1. 手动执行writer.Flush()将缓冲区数据刷入文件，同时检查flush是否出错
2. 调用file.Seek(0, io.SeekStart)将文件指针复位到文件开头位置

修复后的核心代码片段：

// 原有循环写入csv逻辑
for _, d := range data {
    csvRow := []string{
        d.ID,
        d.Name,
        timestamp,
    }
    err = writer.Write(csvRow)
    if err != nil {
        log.Printf("error writing data to CSV: %v\n", err)
    }
}

// 新增：刷缓冲区+检查错误
writer.Flush()
if err = writer.Error(); err != nil {
    return err
}

// 新增：复位文件指针
_, err = file.Seek(0, io.SeekStart)
if err != nil {
    return err
}

// 原有加载到BigQuery逻辑
source := bigquery.NewReaderSource(file)
source.Schema = bigquery.Schema{
    {Name: "id", Type: bigquery.StringFieldType},
    {Name: "name", Type: bigquery.StringFieldType},
    {Name: "createdAt", Type: bigquery.TimestampFieldType},
}
if _, err = bqClient.LoadCsv(ctx, "tableID", source); err != nil {
    return err
}

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