如何解决如何在Nest中进行批量局部更新而又不先获取商品?
我想在Elasticsearch中使用nest进行批量操作中的一个字段的部分更新。
这是我的代码
public async Task bulkupdate<TOrig,TUpdate>(List<TUpdate> request) where TOrig : class where TUpdate : class
{
ConnectionSettings settings = new ConnectionSettings(new Uri(Url))
.DefaultIndex(IndexName);
Elasticclient client = new Elasticclient(settings);
BulkResponse response = await client.BulkAsync(b =>
b.UpdateMany<TOrig,TUpdate>(request,(bu,doc) =>
bu.Doc(doc)));
}
然后我想这样称呼它:
foreach (GetRecycleBinResult recyclingItem in recyclingItems)
{
bulkRequest.Add(new MarkFileDeletedRequest { Id = recyclingItem.Id,Deleted = true });
}
await indexer.bulkupdate(bulkRequest);
这是我想要要做的,但是它不会让我这样做,因为它希望request
和doc
的类型为TOrig
,而我希望它们成为局部变量(TUpdate
)。我看过的示例首先显示了从Elasticsearch获取结果的结果,然后将其传递到我有request
的位置,但这效率极低,并且与首先发出大量请求的整个观点背道而驰地方。
更新
我可以使用BulkDescriptor
类来做到这一点:
ConnectionSettings settings = new ConnectionSettings(new Uri(Url))
.DefaultIndex(IndexName);
Elasticclient client = new Elasticclient(settings);
BulkDescriptor descriptor = new BulkDescriptor();
foreach (keyvaluePair<Guid,TUpdate> item in request)
{
descriptor.Update<TOrig,TUpdate>(a => a.Id(item.Key).Doc(item.Value));
}
BulkResponse response = await client.BulkAsync(descriptor);
但是为什么它不能与流畅的API一起使用?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。