如何使用Elasticsearch Go类型化客户端批量插入文档？

错误原因 #

你代码中req.CreateOp(types.NewCreateOperation(), doc)报错的核心原因是类型化客户端的Bulk操作API用法错误：bulk.Index()返回的是索引请求构建器，并不存在符合该参数的CreateOp方法，正确的创建/插入操作应该用专门的bulk.Create()或bulk.Index()方法来构建。

正确实现代码 #

批量创建文档（仅当文档ID不存在时插入） #

import (
    "context"
    "github.com/elastic/go-elasticsearch/v8"
)

// 初始化类型化客户端
typedClient, err := elasticsearch.NewTypedClient(elasticsearch.Config{
    Addresses: addresses,
    Username:  username,
    Password:  password,
})
if err != nil {
    // 此处处理客户端初始化错误，比如log.Fatal(err)
}

// 创建Bulk请求实例
bulkReq := typedClient.Bulk()

// 遍历文档列表，添加创建操作
for _, doc := range docs {
    // 为每个文档添加Create操作，指定目标索引
    bulkReq.Create(indexName).Document(doc)
    
    // 如果需要指定自定义文档ID，可添加Id方法：
    // bulkReq.Create(indexName).Id(doc.ID).Document(doc)
}

// 执行批量请求
res, err := bulkReq.Do(context.Background())
if err != nil {
    // 处理批量执行错误
}
// 处理响应结果，比如检查res.Errors判断是否有操作失败

批量索引文档（存在则覆盖，不存在则插入） #

如果业务允许覆盖已有ID的文档，可使用Index操作替代Create，写法几乎一致：

for _, doc := range docs {
    bulkReq.Index(indexName).Document(doc)
    // 指定ID：bulkReq.Index(indexName).Id(doc.ID).Document(doc)
}

关键说明 #

• 类型化客户端的Bulk操作通过链式调用构建，每个Create/Index方法都会向批量请求中添加一个操作
• Document()方法直接接收你的文档结构体（需能序列化为JSON），无需手动创建CreateOperation
• 执行Do(context.Background())会发送批量请求到Elasticsearch，返回的响应中Errors字段为true时表示有操作失败，可遍历Items查看具体错误

内容的提问来源于stack exchange，提问作者khateeb