Go语言CSV写入教程：解决数据未写入文件的常见问题

package main

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

// 模拟一些错误数据，实际应用中可能来自其他逻辑
var errorsData = map[string][]string{
    "group1": {"value1_1", "value1_2", "value1_3", "value1_4", "error_desc_1"},
    "group2": {"value2_1", "value2_2", "value2_3", "value2_4", "error_desc_2"},
}

func writeCSVDataIncorrect() {
    // 以追加模式打开或创建文件，并设置文件权限
    file, err := os.OpenFile("output_incorrect.csv", os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0666)
    if err != nil {
        panic(err) // 处理文件打开错误
    }
    defer file.Close() // 确保文件在函数结束时关闭

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

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

    // 遍历数据并写入
    for key, value := range errorsData {
        // 这里假设value已经包含了key作为第一列，或者key是额外信息
        // 为了简化示例，我们直接写入value
        if err := writer.Write(value); err != nil {
            fmt.Printf("写入数据行失败: %v\n", err)
        }
        fmt.Printf("尝试写入: %s, %v\n", key, value)
    }

    fmt.Println("数据写入操作已完成 (但可能未刷新到文件).")
    // 问题在于：这里缺少了关键的刷新操作
}

func main() {
    writeCSVDataIncorrect()
    fmt.Println("请检查 output_incorrect.csv 文件，它可能为空或不完整。")
}

func (w *Writer) Flush()

package main

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

// 模拟一些错误数据，实际应用中可能来自其他逻辑
var errorsDataCorrect = map[string][]string{
    "group1": {"value1_1", "value1_2", "value1_3", "value1_4", "error_desc_1"},
    "group2": {"value2_1", "value2_2", "value2_3", "value2_4", "error_desc_2"},
    "group3": {"value3_1", "value3_2", "value3_3", "value3_4", "error_desc_3"},
}

func writeCSVDataCorrect() {
    // 以追加模式打开或创建文件，并设置文件权限
    // os.O_WRONLY 是推荐的写入模式，os.O_APPEND 会在每次写入时定位到文件末尾
    file, err := os.OpenFile("output_correct.csv", os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0666)
    if err != nil {
        panic(err) // 处理文件打开错误
    }
    defer file.Close() // 确保文件在函数结束时关闭

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

    // 写入CSV头部
    headers := []string{"group_id", "account_id", "location_id", "payment_rating", "records_with_error"}
    if err := writer.Write(headers); err != nil {
        fmt.Printf("写入头部失败: %v\n", err)
        return // 写入失败，提前退出
    }

    // 遍历数据并写入
    for key, value := range errorsDataCorrect {
        // 为了示例更贴合实际，我们可以在这里组合数据
        // 例如：record := append([]string{key}, value...)
        if err := writer.Write(value); err != nil {
            fmt.Printf("写入数据行失败: %v\n", err)
            // 根据业务需求决定是否继续或中断
        }
        fmt.Printf("已写入缓冲区: %s, %v\n", key, value)
    }

    // !!! 关键步骤：调用Flush()将缓冲区数据写入文件 !!!
    writer.Flush()
    if err := writer.Error(); err != nil { // 检查Flush()后是否有写入错误
        fmt.Printf("刷新缓冲区时发生错误: %v\n", err)
        return
    }

    fmt.Println("数据已成功写入并刷新到 output_correct.csv 文件。")
}

func main() {
    writeCSVDataCorrect()
    fmt.Println("请检查 output_correct.csv 文件，现在它应该包含所有数据。")
}