使用UpdateByQueryAsync在Elasticsearch中使用嵌套进行部分更新

{
  "name": "John Doe",
  "age": 30,
  "addresses": [
    {
      "city": "New York",
      "zip": "10001"
    },
    {
      "city": "Los Angeles",
      "zip": "90001"
    }
  ]
}

using Nest;
using System.Threading.Tasks;

public class ElasticsearchExample
{
    private static ElasticClient client = new ElasticClient(new ConnectionSettings(new Uri("http://localhost:9200")));

    public static async Task UpdateAddressesAsync()
    {
        var updateResponse = await client.UpdateByQueryAsync<UsersDocument>(u => u
            .Query(q => q
                .Nested(n => n
                    .Path(p => p.Addresses)
                    .Query(qn => qn
                        .Match(m => m
                            .Field(f => f.Addresses.First().City)
                            .Query("New York")
                        )
                    )
                )
            )
            .Script(sc => sc
                .Inline("ctx._source.addresses[index].zip = params.newZip",
                    new Dictionary<string, object> { { "newZip", "10002" } })
                .Lang("painless")
                .Params(new Dictionary<string, object> { { "index", ctx => ctx.Source.Addresses.IndexOf(ctx._source.Addresses) } })
            )
        );

        Console.WriteLine($"Updated {updateResponse.Total} documents.");
    }
}

public class UsersDocument
{
    public string Name { get; set; }
    public int Age { get; set; }
    public List<Address> Addresses { get; set; }
}

public class Address
{
    public string City { get; set; }
    public string Zip { get; set; }
}