问题描述
我想在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 (将#修改为@)