Go encoding/csv 怎样用字段位置报告坏行

CSV 导入最难排查的不是“解析失败”，而是失败日志只留下一个错误字符串。Go 的 encoding/csv 可以把定位信息补齐：读取成功后，用 Reader.FieldPos 查询最近一条记录中某个字段的起始行和列；读取失败时，再从 csv.ParseError 取出记录起始行、出错行、字节列和底层原因。这样日志能回答“哪一行、哪一列、哪一种坏法”，而不必重新手写 CSV 扫描器。

先把记录读取和错误上下文放在一起

不要先调用 ReadAll 再猜坏行。导入服务更适合逐条读取：每次成功得到记录，就可以按字段索引输出来源位置；每次失败，就立即保留当前错误并停止或进入隔离队列。下面的示例只使用标准库，重点是错误分层和资源关闭。

package main

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

func main() {
	f, err := os.Open("orders.csv")
	if err != nil {
		fmt.Println("打开 CSV 失败：", err)
		return
	}
	defer f.Close() // 读取结束后释放文件描述符。

	r := csv.NewReader(f)
	r.FieldsPerRecord = -1 // 先允许变长记录，便于记录实际坏行位置。
	for {
		record, err := r.Read()
		if err == io.EOF {
			break // 正常读完，不把 EOF 当作坏行。
		}
		if err != nil {
			var parseErr *csv.ParseError
			if errors.As(err, &parseErr) {
				fmt.Printf("CSV 语法错误：起始行=%d 出错行=%d 字节列=%d 原因=%v\\n",
					parseErr.StartLine, parseErr.Line, parseErr.Column, parseErr.Err)
			} else if errors.Is(err, csv.ErrFieldCount) {
				fmt.Println("CSV 字段数不一致：", err)
			} else {
				fmt.Println("CSV 读取失败：", err)
			}
			break // 当前示例选择停止；批处理可改为隔离后继续。
		}

		if len(record) > 1 {
			line, column := r.FieldPos(1) // 索引1是第二列，位置属于本次 Read。
			fmt.Printf("订单号=%q，第二列起点：第%d行第%d字节\\n", record[1], line, column)
		}
	}
}

这里把 FieldsPerRecord 设为 -1，是为了让变长记录先进入日志，而不是被字段数检查提前截断。如果业务要求每行固定列数，可以让第一条记录自动设定数量，或显式设置正数；两种策略都不改变 FieldPos 的“最近一次成功 Read”语义。

FieldPos 报告的是字段起点，不是错误终点

FieldPos(field) 返回字段在 CSV 原文中的起始位置，行号和列号都从 1 开始。列号按字节计算，不按 Unicode 字符或屏幕宽度计算；例如字段前出现中文时，日志中的列号可能比肉眼数出的字符位置更大。它也只保存最近一条 Read 返回记录的位置，下一次读取后就应立即把需要的信息写入日志。

调用前先检查索引：field >= 0 && field 。官方实现对负数或超出最近记录字段数的索引会直接 panic，因此不能把“可能存在的列”直接传给 FieldPos。如果要输出整行字段位置，可以在同一次 Read 后遍历 record，而不是保存 Reader 的内部状态。

ParseError 与 FieldPos 怎么分工

两者解决的是不同阶段的问题：

ParseError.Column 是解析器判断错误的位置，FieldPos 是已成功字段的起始位置，不能把两者当成同一坐标。若需要跳过坏行，建议把文件偏移 Reader.InputOffset()、错误行和原始批次标识一并记录；偏移表示最近读完行的末尾与下一行开头，适合做重放线索，但不是字段列号。

上线前的定位清单

• 日志明确写“字节列”，不要把列号描述成字符序号。
• 调用 FieldPos 前检查字段索引，且紧跟当前 Read 使用。
• 把 ParseError 的 StartLine、Line、Column、Err 分开记录。
• 明确 FieldsPerRecord 是严格校验还是允许变长；否则同一批文件的日志含义会漂移。
• 异常记录需要重放时，再补充 InputOffset 和文件批次 ID，不要用偏移代替行列位置。

常见问题

FieldPos 的列号为什么和中文字符数对不上？

因为官方定义按字节计列，不按 Unicode rune 计数。日志字段名应写成“字节列”，需要展示字符位置时再单独转换，不能修改标准库返回值。

Read 返回错误时还能调用 FieldPos 吗？

不要把它当作坏字段的定位 API。解析失败时优先读取 ParseError；只有拿到成功返回的记录并确认字段索引有效时，才用 FieldPos 标记已解析字段。

InputOffset 能替代 FieldPos 吗？

不能。InputOffset 是输入流的行边界字节偏移，FieldPos 是字段起始的行列位置。前者适合重放和切片线索，后者适合人读日志和字段级提示。