Go连接Elasticsearch推荐使用elastic/go-elasticsearch客户端，需匹配ES大版本；初始化时须配置Transport（认证、HTTPS、超时等）；创建Index要符合8.x mapping规范；Bulk写入需检查错误并解析响应体。
Go 连接 Elasticsearch 需要什么客户端
Go 官方不提供 Elasticsearch SDK，主流选择是 olivere/elastic（v7 及以前）或 elastic/go-elasticsearch（官方维护，v7.15+ 推荐）。注意：olivere/elastic 已归档，新项目别再用；elastic/go-elasticsearch 是当前唯一持续更新的 Go 客户端。
安装命令：
go get github.com/elastic/go-elasticsearch/v8
注意版本后缀 v8 要和你部署的 ES 服务大版本一致（如 ES 8.10 → 用 v8；ES 7.17 → 用 v7），否则可能因 API 不兼容导致 400 Bad Request 或序列化失败。
初始化 client 时必须处理哪些配置项
最常漏掉的是 Transport 层配置 —— 默认 client 会尝试连接 http://localhost:9200，但生产环境通常有认证、HTTPS、自签名证书等。不显式配置会导致连接拒绝或 TLS handshake timeout。
立即学习“go语言免费学习笔记（深入）”；
-
es, err := elasticsearch.NewDefaultClient()仅适用于本地无认证调试 - 带 Basic Auth：用
elasticsearch.NewClient()+elasticsearch.Config{Username: "...", Password: "..."} - 自签名 HTTPS：必须传入自定义
http.Transport，设置TLSClientConfig.InsecureSkipVerify = true（开发可接受，生产应加载 CA 证书） - 超时控制：通过
Config.Transport设置Timeout和MaxIdleConnsPerHost，避免连接池耗尽
Index 创建失败常见原因
调用 client.Indices.Create 返回 400 Bad Request 或 406 Not Acceptable，大概率是 mapping 定义不合法。ES 8.x 默认禁用 type，且要求显式声明 dynamic 和 properties。
错误示例（ES 8+ 会拒收）：
body := strings.NewReader(`{"mappings": {"properties": {"name": {"type": "text"}}}}`)
正确写法（注意外层无 type，且 properties 必须存在）：
body := strings.NewReader(`{"mappings": {"dynamic": false, "properties": {"name": {"type": "text"}, "age": {"type": "integer"}}}}`)
- 字段名不能含点号（
.）或大写字母，否则报invalid_type_name_exception - 如果 index 已存在且 mapping 不兼容（比如把
text改成keyword），ES 不允许修改，只能删重建或加新字段 - 建议首次创建前用
client.Indices.Exists检查，避免重复创建报错
Bulk 写入时如何避免 panic 和丢数据
client.Bulk 是无返回值的流式接口，出错不会 panic，但错误被静默吞掉 —— 这是最容易被忽略的风险点。
- 必须检查
res.IsError()，再读取res.Body解析 JSON 获取具体失败条目（items数组里的error字段） - 单次 bulk 请求不要超过 10MB 或 1000 条文档，否则易触发
413 Payload Too Large或 OOM - 推荐封装 retry 逻辑：对
429 Too Many Requests和网络超时做指数退避重试，其他错误（如 mapping conflict）需人工介入 - 别用
context.Background()，务必传入带 timeout 的 context，防止 bulk 卡死整个 goroutine
ES 的 bulk 响应体结构复杂，错误信息藏得深，不主动解析 res.Body 就等于没做错误处理。
