搜索2天后,我找到了重新索引索引的解决方案。为了解决将来的问题,我将提供解决方案。
Nest版本-5.4
var reindex = client.Reindex<object>(r => r .BackPressureFactor(10) // ScrollAll - Scroll all the documents of the index and store it for 1minute .ScrollAll("1m", 2, s => s .Search(ss => ss.Index(oldIndexName) .AllTypes())// there needs to be some degree of parallelism for this to work.MaxDegreeOfParallelism(4)) .CreateIndex(c => c // New index here .Index(newIndexName) .Settings(// settings goes here) .Mappings(// mappings goes here)) .BulkAll(b => b // New index here! .Index(newIndexName) .Size(100) .MaxDegreeOfParallelism(2) .RefreshonCompleted()));
ReIndex方法返回一个冷的 IObservable ,您必须在其上调用 .Subscribe() 以启动所有 *** 作。
因此,您需要将其添加到您的代码中:
var o = new ReindexObserver( onError: (e) => { //do something }, onCompleted: () => { //do something });reindex.Subscribe(o);
进行检查的有用链接是:
GitHub上的第2660期
GitHub上的问题2771
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)