C# Nest，弹性搜索：更新并添加到作为列表的字段

Question

这可能是一个愚蠢的问题，但我是弹性搜索和嵌套的新手。

我有课

Person
{
     public string Id {get; set;}
     public string Name {get; set;}
     public IList<string> PhoneNumbers {get; set;}
}

我想做的是通过添加来更新电话号码。

现在我用 2 个查询来做，但我想知道是否有办法用 1 来管理它。

        // See if the Person already exists
        var result = NestClient.Search<Person>(s => s
        .Index(_indexName)
        .Take(1)
        .Query(q => q
        .Term(p => p.Name, person.Name)
        && q.Term(p => p.Id, person.Id)));

        if (result.ServerError != null)
        { 
            throw result.OriginalException;

        }
        if (result.Documents.FirstOrDefault() == null)
        {
            var response = NestClient.Index<Person>(person);
            if (response.ServerError != null)
            {
                throw response.OriginalException;
            }
        }
        else
        {
            // If it does exist update and overwrite
            var savedPerson = result.Documents.First();

            IList<string> oldNums = SavedPerson.PhoneNumbers;
            IList<string> newNums = newPerson.PhoneNumbers;
            var combinedNums = oldNums.Concat(newNums);

            newPerson.PhoneNumbers = combinedNums.ToList<string>();

            var response = NestClient.Update(DocumentPath<Person>
                .Id(newPerson.Id),
                u => u.Doc(newPerson).DocAsUpsert(true));
            if (response.ServerError != null)
            {
                throw response.OriginalException;
            }
        }

基本上我希望我的 upsert 添加到现有的电话号码列表（如果存在）。

Answer 1

如果脚本是一个选项，您可以使用scripted update 执行此操作。

在数组中更新后具有重复项的选项

var updateResponse = client.Update<Document, DocumentPartial>(DocumentPath<Document>.Id(1), descriptor => descriptor
    .Script(@"ctx._source.array += tab;")
    .Params(p => p.Add("tab", new[] {4, 5, 3})));

没有

var updateResponse = client.Update<Document, DocumentPartial>(DocumentPath<Document>.Id(1), descriptor => descriptor
    .Script(@"ctx._source.array += tab; ctx._source.array.unique();")
    .Params(p => p.Add("tab", new[] {4, 5, 3})));

完整示例：

public class DocumentPartial
{ 
    public int[] Array { get; set; }
}

public class Document
{
    public int Id { get; set; } 

    public int[] Array { get; set; }
}

var client = new ElasticClient(settings); 

client.CreateIndex(indexName, descriptor => descriptor
    .Mappings(map => map
        .Map<Document>(m => m.AutoMap()))); 

var items = new List<Document>
{
    new Document
    {
        Id = 1, 
        Array = new[] {1,2,3}
    } 
};

var bulkResponse = client.IndexMany(items);

client.Refresh(indexName);

var updateResponse = client.Update<Document, DocumentPartial>(DocumentPath<Document>.Id(1), descriptor => descriptor
    .Script(@"ctx._source.array += tab; ctx._source.array.unique();")
    .Params(p => p.Add("tab", new[] {4, 5, 3})));

希望对你有帮助。