Elasticsearch - NEST - Upsert

Question

我有以下两门课

条目

public class Entry
{
    public Guid Id { get; set; }
    public IEnumerable<Data> Data { get; set; }
}

EntryData

public class EntryData
{
    public string Type { get; set; }
    public object Data { get; set; }
}

我有一组不同的应用程序，它们向队列生成消息，然后在单独的应用程序中使用该队列，以便将数据存储在elasticsearch中。

我对所有消息使用一个CorrelationId，我希望在elasticsearch中使用这个ID作为ID。因此，鉴于以下数据：

var id = Guid.Parse("1befd5b62b944b4aa600c85632159e11");
var entries = new List<Entry>
{
    new Entry
    {
        Id = id,
        Data = new List<EntryData>
        {
           new EntryData
            {
                Data = DateTime.UtcNow,
                Type = "APPLICATION1_Received"
            },
            new EntryData
            {
                Data = DateTime.UtcNow,
                Type = "APPLICATION1_Validated"
            },
            new EntryData
            {
                Data = DateTime.UtcNow,
                Type = "APPLICATION1_Published"
            },
        }
    },
    new Entry
    {
        Id = id,
        Data = new List<EntryData>
        {
           new EntryData
            {
                Data = DateTime.UtcNow,
                Type = "APPLICATION2_Received"
            },
            new EntryData
            {
                Data = DateTime.UtcNow,
                Type = "APPLICATION2_Validated"
            },
            new EntryData
            {
                Data = DateTime.UtcNow,
                Type = "APPLICATION2_Published"
            },
        }
    },
    new Entry
    {
        Id = id,
        Data = new List<EntryData>
        {
           new EntryData
            {
                Data = DateTime.UtcNow,
                Type = "APPLICATION3_Received"
            },
            new EntryData
            {
                Data = DateTime.UtcNow,
                Type = "APPLICATION3_Validated"
            },
            new EntryData
            {
                Data = DateTime.UtcNow,
                Type = "APPLICATION3_Published"
            },
        }
    },

};

我希望将其保存为elasticsearch中的one entry，其中ID == 1befd5b6-2b94-4b4a-a600-c85632159e11和包含9元素的data数组。

当我试着做以下几件事时，我有点为让它起作用而挣扎：

var result = await _elasticClient.BulkAsync(x => x.Index("journal").UpdateMany(entries, (descriptor, entry) => {
    descriptor.Doc(entry);
    return descriptor.Upsert(entry);
}), cancellationToken);

但是这只是覆盖数据数组中已经存在的内容，计数是3而不是9(只保存了Application3条目)。

那么，能不能做我想做的事呢？我以前从未和elasticsearch合作过，所以感觉好像我错过了一些简单的东西。:)

Answer 1

设法像这样解决这个问题：

var result = await _elasticClient.BulkAsync(x => x.Index("journal").UpdateMany(entries, (descriptor, entry) => {
    var script = new InlineScript("ctx._source.data.addAll(params.data)")
    {
        Params = new Dictionary<string, object> {{"data", entry.Data}}
    };
    descriptor.Script(b => script);
    return descriptor.Upsert(entry);
}), cancellationToken);