如何在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);

这是我想要要做的,但是它不会让我这样做,因为它希望requestdoc的类型为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 (将#修改为@)

相关问答

Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其...
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。...
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbc...