Как обновить вложенные объекты с помощью Nest Elasticsearch? - PullRequest
Новая
       10

Как обновить вложенные объекты с помощью Nest Elasticsearch?

0 голосов
/ 31 января 2019

У меня есть индекс продукта, который для простоты имеет два поля Id и ProductAttributes как вложенный объект, определенный следующим образом: 

public class ProductType
{
    public Guid Id { get; set; }

    public List<ProductAttribute> ProductAttributes { get; set; }
 }

public class ProductAttribute
{
    public Guid Id { get; set; }

    public string Name { get; set; }

    public string Value { get; set; }
}

И следующее отображение: 

elasticClient.CreateIndex("product", i => i
       .Settings(s => s
                 .NumberOfShards(2)
                 .NumberOfReplicas(0)
                 )
                 .Mappings(m => m
                   .Map<ProductType>(map => map
                         .AutoMap()
                         .Properties(p => p
                          .Nested<ProductAttribute>(n => n
                            .Name(c => c.ProductAttributes)
                            .AutoMap()
                            .Properties(nc => nc
                               .Keyword(t => t
                                   .Name(nn => nn.Name)
                                   )
                              .Keyword(t => t
                                .Name(nn => nn.Value)
                             )
                  )
             )

Теперь я пытаюсьобновить поле имени внутри вложенного объекта, и я попытался реализовать это с помощью обновления по сценарию следующим образом: 

        var scriptParams = new Dictionary<string, object>
                            {
                                {"name", "new name"}
                            };

        var result = elasticClient.UpdateByQuery<ProductType>(u => u
                              .Script(sn => sn
                                   .Inline(
                                          $"ctx._source.productAttributes= params.name;" 
                                      )
                                  .Params(scriptParams)
                              )
                              .Conflicts(Conflicts.Proceed)
                              .Refresh(true)
                          );

Но, используя приведенный выше запрос, я не смог обновить вложенный объект, не могли бы вы сказать, как я могу обновитьвложенный объект, используя _update_by_query API, используя гнездо ES?

Ответы [ 2 ]

0 голосов
/ 01 февраля 2019

Наконец-то я нашел способ обновить свойство name только для определенных вложенных объектов в зависимости от их идентификатора следующим образом: 

var result = elasticClient.UpdateByQuery<ProductType>(u => u
                  .Query(q => q
                        .Nested(n => n
                          .Path(Infer.Field<ProductType>(ff => ff.ProductAttributes))
                          .Query(nq => nq
                              .Term(Infer.Field<ProductType>(ff => ff.ProductAttributes.First().Id), productAttributeId)
                          )
                        )
                  )
                  .Script(ss => ss.Inline("if (ctx._source.productAttributes != null){for (item in ctx._source.productAttributes){if (item.id == params.id) {item.name = params.name;}}}")
                     .Params(new Dictionary<string, object>()
                     {
                         {"id", productAttributeId},
                         {"name", productAttributeName}
                     }).Lang("painless")
                  )
                  .Conflicts(Conflicts.Proceed)
                  .Refresh(true)
              );

А вот сгенерированный запрос: 

 POST product/producttype/_update_by_query?conflicts=proceed&refresh=true 
{
  "query": {
    "bool": {
      "must": [
        {
          "nested": {
            "query": {
              "term": {
                "productAttributes.id": {
                  "value": "563243f0-8fbb-4adf-a78d-1339e5971a43"
                }
              }
            },
            "path": "productAttributes"
          }
        }
      ]
    }
  },
  "script": {
    "params": {
        "id":"563243f0-8fbb-4adf-a78d-1339e5971a43",
        "name": "CPU"
    },
    "lang": "painless",
    "inline": "if (ctx._source.productAttributes != null){for (item in ctx._source.productAttributes){if (item.id == params.id) {item.name = params.name;}}}"
  }
}

Так чтовыполняет ли приведенный выше запрос:

Сначала выполняется поиск продуктов, имеющих атрибут productAttribute с идентификатором 563243f0-8fbb-4adf-a78d-1339e5971a43 , а затем он перебирает вложенные объекты productAttributes для обновления только атрибутов сэтот идентификатор, а затем снова индексирует документ.

Я надеюсь, что мой ответ поможет другим, столкнувшимся с проблемами при обновлении вложенных объектов в Elasticsearch.

0 голосов
/ 01 февраля 2019

Смотрите, вот в чем проблема: $ "ctx._source.productAttributes = params.name;"

productAttributes - это объект (гнездовой объект), а params.name - это значение (строка) и то, на что ES жалуется в ответе на запрос.

Не уверен, что именно вы хотите сделать, если вашТребуется обновить имя для всех элементов productAttributes, которые вы можете попробовать: 

        var result = elasticClient.UpdateByQuery<ProductType>(u => u
            .Index("product")
            .Script(ss => ss.Source("for(int i=0; i<ctx._source.productAttributes.size(); i++){HashMap myKV = ctx._source.productAttributes.get(i);myKV.put(params.item.fieldName, params.item.fieldValue);}")
                        .Params(d => d.Add("item", new Dictionary<string, object>()
                        {
                            {"fieldName", "name" },
                            {"fieldValue", "new name" }
                        })).Lang("painless")));
...