问题

我想使用Go包elastic中的BulkIndexRequest。我尝试查找示例，但似乎没有找到。所以如果有人使用过它，能否帮助我创建以下请求？

import (
    "context"
    "github.com/olivere/elastic/v7"
)

func main() {
    client, err := elastic.NewClient()
    if err != nil {
        // 处理错误
    }

    request := client.Bulk().Index("someindex").Type("sometype")

    // 添加第一个文档
    doc1 := map[string]interface{}{
        "index": map[string]interface{}{
            "_id": "existing_id",
        },
    }
    request.Add(doc1)

    // 添加第二个文档
    doc2 := map[string]interface{}{
        "field1": "test1",
    }
    request.Add(doc2)

    // 添加第三个文档
    doc3 := map[string]interface{}{
        "index": map[string]interface{}{
            "_id": "existing_id2",
        },
    }
    request.Add(doc3)

    // 添加第四个文档
    doc4 := map[string]interface{}{
        "field2": "test2",
    }
    request.Add(doc4)

    // 执行批量索引请求
    response, err := request.Do(context.Background())
    if err != nil {
        // 处理错误
    }

    // 处理响应
    // ...
}

请注意，上述代码仅为示例，你需要根据实际情况进行适当的修改和错误处理。

curl -s -H "Content-Type: application/json" -XPOST localhost:9200/someindex/sometype/_bulk -d'
{ "index": {"_id": "existing_id"}}
{ "field1": "test1"}
{ "index": {"_id": "existing_id2"}}
{ "field2": "test2"}
'

答案1

得分: 2

你可以在test classes中找到一些示例，并且在wiki中有很好的解释。它的用法如下：

indexName := "someindex"
typeName  := "sometype"
index1Req := NewBulkIndexRequest().Index(indexName).Type(typeName).Id("existing_id").Doc({...})
index2Req := NewBulkIndexRequest().Index(indexName).Type(typeName).Id("existing_id2").Doc({...})

bulkRequest := client.Bulk()
bulkRequest = bulkRequest.Add(index1Req)
bulkRequest = bulkRequest.Add(index2Req)

bulkResponse, err := bulkRequest.Do(context.TODO())
if err != nil {
	t.Fatal(err)
}
...

indexName := "someindex"
typeName  := "sometype"
index1Req := NewBulkIndexRequest().Index(indexName).Type(typeName).Id("existing_id").Doc({...})
index2Req := NewBulkIndexRequest().Index(indexName).Type(typeName).Id("existing_id2").Doc({...})

bulkRequest := client.Bulk()
bulkRequest = bulkRequest.Add(index1Req)
bulkRequest = bulkRequest.Add(index2Req)

bulkResponse, err := bulkRequest.Do(context.TODO())
if err != nil {
	t.Fatal(err)
}
...