我正在使用Olivere / elastic与Go中的elasticsearch一起工作。这是我的代码:// (1) delete document _, err := e.client.Delete().Index(index).Type("entity"). Id(id).Do(e.ctx)if err != nil { fmt.Println(err.Error())}// (2) get all documents result, err := e.client.Search().Index(index).From(1).Size(100).Do(e.ctx)if err != nil { log.Println(err)}fmt.Println(result.TotalHits())// (3) waittime.Sleep(3 * time.Second)// (4) get all documentsresult, err = e.client.Search().Index(index).From(1).Size(100).Do(e.ctx)if err != nil { log.Println(err)}fmt.Println(result.TotalHits())我在这里:删除文件从集合中获取所有文件等待3秒从集合中获取相同的文档现在,在步骤(2)上,我得到的文档比步骤(4)多得多。看来文档在Elastic中被删除有些延迟,我正在寻找同步删除文档的方法。
1 回答
ibeautiful
TA贡献1993条经验 获得超5个赞
_, err := e.client.Delete().Index(index).Type("entity").
Id(id).Refresh("true").Do(e.ctx)
刷新(“ true”)
- 1 回答
- 0 关注
- 257 浏览
添加回答
举报
0/150
提交
取消