使用弹性搜索更新文档

Question

我使用go弹性搜索作为弹性搜索客户端。

我试图使用这里的代码更新文档elastic/go-elasticsearch/api.update.go-

然而，使用GitHub中的相同代码，我得到了：

[UpdateRequest] unknown field [Title]

到目前为止，我只有一份文件看起来像这个

{
"took": 3,
"timed_out": false,
"_shards": {
"total": 4,
"successful": 4,
"skipped": 0,
"failed": 0
},
"hits": {
"total": {
"value": 1,
"relation": "eq"
},
"max_score": 1.0,
"hits": [
{
"_index": "posts",
"_type": "_doc",
"_id": "fc87941f-dc82-4fdb-9e04-460830e5f3ab",
"_score": 1.0,
"_source": {
"Title": "one two three2",
"Done": false,
"Created": "2022-02-09T11:51:59.027356+01:00",
"Updated": null
}
}
]
}
}

我的go功能：

func (postRepository) Update(id uuid.UUID, input inputs.Post) error {
channel := make(chan error)
go func() {
post := entities.Post{
Title:   "title updated",
}
body, err := json.Marshal(post)
if err != nil {
channel <- err
}
request := esapi.UpdateRequest{
Index:      index,
DocumentID: id.String(),
Body:       strings.NewReader(string(body)),
}
response, err := request.Do(context.Background(), data.ElasticSearchClient)
if err != nil {
channel <- err
}
defer response.Body.Close()
if response.IsError() {
var b map[string]interface{}
e := json.NewDecoder(response.Body).Decode(&b)
if e != nil {
fmt.Println(fmt.Errorf("error parsing the response body: %s", err))
}
fmt.Println(fmt.Errorf("reason: %s", b["error"].(map[string]interface{})["reason"].(string)))
channel <- fmt.Errorf("[%s] Error indexing document", response.Status())
}
channel <- nil
}()
return <-channel
}

我的实体：

type Post struct {
Title   string
Done    bool
Created time.Time
Updated *time.Time
}

此外，这是唯一一个不起作用的函数，其他函数如：AddDocument、RemoveDocument、GetDocuments都按预期起作用。

Answer 1

在此处找到解决方案：a-简单弹性搜索-crud-sample-in-golang

代替使用：

request := esapi.UpdateRequest{
Index:      index,
DocumentID: id.String(),
Body:       strings.NewReader(string(body)),
}

使用

request := esapi.UpdateRequest{
Index:      index,
DocumentID: id.String(),
Body: bytes.NewReader([]byte(fmt.Sprintf(`{"doc":%s}`, body))),
}