Go语言encoding/csv写入数据不生效：Flush方法的关键作用

func (w *Writer) Flush()

package main

import (
    "encoding/csv"
    "fmt"
    "os"
)

// writeDataToCSV 演示了如何正确地将数据写入CSV文件
// 参数 data 是一个map，其中键是字符串，值是字符串切片，代表CSV的每一行数据
func writeDataToCSV(filename string, data map[string][]string) {
    // 1. 打开或创建CSV文件
    // os.O_APPEND: 如果文件存在，则追加内容
    // os.O_CREATE: 如果文件不存在，则创建文件
    // os.O_WRONLY: 以只写模式打开文件
    // 0666: 文件权限，允许所有用户读写
    file, err := os.OpenFile(filename, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0666)
    if err != nil {
        panic(fmt.Errorf("无法打开或创建文件 %s: %w", filename, err))
    }
    // 确保文件在函数退出时关闭，释放资源
    defer file.Close()

    // 2. 创建一个新的CSV写入器
    writer := csv.NewWriter(file)

    // 3. 写入CSV头部
    headers := []string{"group_id", "account_id", "location_id", "payment_rating", "records_with_error"}
    if writeErr := writer.Write(headers); writeErr != nil {
        fmt.Printf("写入头部错误: %v\n", writeErr)
        return
    }

    // 4. 遍历数据并写入每一行
    for key, value := range data {
        if writeErr := writer.Write(value); writeErr != nil {
            fmt.Printf("写入数据行 (%s: %v) 错误: %v\n", key, value, writeErr)
            // 根据实际需求，可以选择继续写入其他行或提前退出
            continue
        }
        fmt.Printf("正在写入数据行: %s, %v\n", key, value)
    }

    // 5. 关键步骤：调用 Flush() 将所有缓冲数据写入文件
    writer.Flush()

    // 6. 检查 Flush 操作后是否有错误发生
    // writer.Error() 方法返回在写入过程中遇到的任何错误
    if flushErr := writer.Error(); flushErr != nil {
        fmt.Printf("Flush操作错误: %v\n", flushErr)
    } else {
        fmt.Printf("所有数据已成功写入文件 '%s'。\n", filename)
    }
}

func main() {
    // 示例数据
    sampleErrors := map[string][]string{
        "transaction_001": {"GRP001", "ACC123", "LOCA", "A", "InvalidAmount"},
        "transaction_002": {"GRP002", "ACC456", "LOCB", "B", "MissingField"},
        "transaction_003": {"GRP003", "ACC789", "LOCC", "C", "DataCorruption"},
    }

    // 调用函数写入CSV
    writeDataToCSV("output.csv", sampleErrors)
}