我正在使用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)多得多??磥砦臋n在Elastic中被刪除有些延遲,我正在尋找同步刪除文檔的方法。
1 回答

ibeautiful
TA貢獻1993條經驗 獲得超6個贊
_, err := e.client.Delete().Index(index).Type("entity").
Id(id).Refresh("true").Do(e.ctx)
刷新(“ true”)
- 1 回答
- 0 關注
- 292 瀏覽
添加回答
舉報
0/150
提交
取消