Elasticsearch NEST是否支持Update By Query？寻求相关文档与示例

我太懂这种找不到对应NEST文档的郁闷了！其实NEST的UpdateByQuery方法和Elasticsearch的REST API对应得非常紧密，我整理了几个实用的使用示例，应该能帮到你：

基础脚本更新 #

最常用的场景：匹配符合条件的文档，通过Painless脚本修改字段值

var response = await client.UpdateByQueryAsync<MyDocument>(u => u
    .Index("your-index-name") // 指定要操作的索引
    .Query(q => q
        .Match(m => m
            .Field(f => f.Status) // 匹配Status字段
            .Query("inactive")    // 匹配值为"inactive"的文档
        )
    )
    .Script(s => s
        .Source("ctx._source.status = 'archived'") // 脚本逻辑：把Status改成'archived'
        .Lang("painless")
    )
);

// 检查操作是否成功
if (!response.IsValid)
{
    // 处理错误，比如查看response.ServerError
}

处理并发冲突 #

UpdateByQuery默认是乐观并发控制，如果遇到版本冲突会停止执行。如果需要忽略冲突继续操作，或者重试冲突的文档：

var response = await client.UpdateByQueryAsync<MyDocument>(u => u
    .Index("your-index-name")
    .Query(q => q.Range(r => r.Field(f => f.CreatedAt).LessThan("2023-01-01")))
    .Script(s => s.Source("ctx._source.archived = true"))
    .Conflicts(Conflicts.Proceed) // 遇到冲突时继续处理其他文档
    .RetryOnConflict(3) // 冲突的文档重试3次
);

直接更新字段（无需脚本） #

如果只是简单替换字段值，也可以用Doc方法直接传入对象，避免写脚本：

var response = await client.UpdateByQueryAsync<MyDocument>(u => u
    .Index("your-index-name")
    .Query(q => q.Term(t => t.Category, "old-category"))
    .Doc(new MyDocument { Category = "new-category" }) // 直接设置要更新的字段
);

批量处理大数量文档 #

如果要更新的文档数量很多，可以通过Scroll和Size参数控制批次，避免内存压力：

var response = await client.UpdateByQueryAsync<MyDocument>(u => u
    .Index("your-index-name")
    .Query(q => q.MatchAll()) // 更新索引里所有文档
    .Script(s => s.Source("ctx._source.view_count += 1")) // 给浏览量加1
    .Scroll("10m") // 滚动查询的上下文保持10分钟
    .Size(1000) // 每次处理1000条文档
);

另外分享个小技巧：NEST的API设计基本和Elasticsearch的REST API一一对应，你可以对照官方的REST版UpdateByQuery文档来反向推导NEST的用法，大部分参数、查询语法都是镜像的，比如REST里的conflicts参数对应NEST里的Conflicts()方法，很好对应。

内容的提问来源于stack exchange，提问作者Russell McDonnell