官方推荐ES 7.x用olivere/elastic/v7，ES 8.x必须用elastic/go-elasticsearch/v8；bulk请求为NDJSON格式，需操作行与文档行成对出现；并发控制建议500–1000条/批、4 goroutine并发，并设60–120s超时。
Go 客户端怎么选 bulk 写入方式？
官方 elastic/v7（或 olivere/elastic）库对 Bulk 支持最稳，但注意 v8 官方 SDK 已弃用 elastic，改用 elastic/go-elasticsearch。如果你用的是 ES 7.x，继续用 olivere/elastic；ES 8.x 则必须切到新 SDK，且 Bulk 接口设计有变化——不是传一堆 IndexRequest 就完事，得手动拼 bytes.Buffer 或用 esapi.BulkReq。
常见错误是混用版本：比如 ES 8.10 + olivere/elastic v7，会卡在连接认证或 400 错误，因为 v7 客户端默认发旧版 bulk 格式（无 index action header），而 ES 8 要求每条操作带 {"index":{...}} 行。
- ES 7.x →
go get github.com/olivere/elastic/v7 - ES 8.x →
go get github.com/elastic/go-elasticsearch/v8 - 别用
gopkg.in/olivere/elastic.v7这类老 import 路径，容易拉错 commit
Bulk 请求体格式到底长什么样？
ES 的 bulk API 不是 JSON 数组，而是换行分隔的 NDJSON（每行一个 JSON 对象），且操作指令行和文档行必须成对出现。比如写入两条文档：
{"index":{"_index":"logs","_id":"1"}}
{"message":"hello","ts":"2024-01-01"}
{"index":{"_index":"logs","_id":"2"}}
{"message":"world","ts":"2024-01-02"}
漏掉任意一行（比如少一个 {"index":{...}}），整个 bulk 请求会失败并返回 400 Bad Request，错误信息里常含 "failed to parse source" 或 "expected json object"。
立即学习“go语言免费学习笔记（深入）”；
Go 配置库，使用 spf13/viper — 分层优先级（flag > env >file > KV > default），提供 BindPFlag/BindPFlags、SetEnvPrefix + SetEnvKeyReplace 等功能。
- 用
olivere/elastic时，调bulk.Add(...)自动组装，不用手拼 - 用
go-elasticsearch/v8时，必须自己构造 buffer：先写 action 行（json.Marshal后加\n），再写 doc 行（同样加\n），最后调es.Bulk()传bytes.NewReader(buf) - 所有 action 行（
index/update/delete）都必须是合法 JSON 对象，不能是空对象{}，至少要带_index
并发写 Bulk 怎么控制吞吐和失败重试？
单次 bulk 太大（比如 >10MB 或 >1000 条）容易触发 ES 的 http.max_content_length（默认 100MB）或 JVM 堆压力；太小（如每次 10 条）则网络开销占比高、QPS 上不去。实测 500–1000 条 / 5–15MB 是较稳妥区间。
失败处理不能只看 HTTP 状态码：bulk 成功返回 200，但响应体里的 errors: true 表示部分条目失败，需解析 response.Errors 和每个 item 的 error.reason（比如 "version conflict" 或 "mapping update rejected"）。
- 别用
time.Sleep做重试，应基于error.reason分类：版本冲突可重试，mapping 错误得改代码 - 并发多个 bulk goroutine 时，用
semaphore控制并发数（比如最多 4 个同时写），避免打爆 ES 连接池 - 每批 bulk 执行后检查
res.Body.Close()，否则文件描述符泄漏，跑几小时就too many open files
为什么本地调试总卡在 context deadline exceeded？
这通常不是 ES 慢，而是 Go 客户端默认的 http.Client.Timeout（30s）不够用。Bulk 写入涉及序列化、网络传输、ES 解析、刷盘，尤其批量大或磁盘慢时很容易超时。
olivere/elastic 允许在 client 初始化时传 elastic.SetHealthcheck(false) 和自定义 http.Transport；go-elasticsearch/v8 则需构造 es.Config 并设置 Transport 字段。
- 把
Timeout设为 60–120s，IdleConnTimeout至少 30s，避免连接被过早关闭 - ES 本地单节点默认不开启 security，但客户端若配置了
username/password，会因 401 卡住——确认elasticsearch.yml里没开xpack.security.enabled: true - 用
curl -v http://localhost:9200/_cat/health?v先验证集群状态，排除 ES 自身问题
bulk 不是“设完就跑”的黑盒，动作行格式、版本对齐、失败粒度、超时阈值，每个点漏掉都会让写入静默失败或性能断崖。尤其是从 v7 切 v8 时，action 行结构和错误解析逻辑几乎全换，别信旧教程的代码片段。
