Elasticsearch：删除/更新嵌套对象内的字段

Question

{
  "_index" : "test",
  "_type" : "test",
  "_id" : "1212",
  "_version" : 5,
  "found" : true,
  "_source" : {
    "count" : 42,
    "list_data" : [ {
      "list_id" : 11,
      "timestamp" : 1469125397
    }, {
      "list_id" : 122,
      "timestamp" : 1469050965
    } ]
  }
}

这是我的文档架构。list_data 是嵌套对象。我需要更新/删除list_data 中的特定文件。我可以使用 groovy 脚本更新 count 字段。

$ curl -XPOST 'localhost:9200/index/type/1212/_update?pretty' -d '
{
    "script" : "ctx._source.count = 41"
}'

但不知道如何更新嵌套对象。

例如，我想将其添加到list_data。

{
   "list_id" : 121,
   "timestamp" : 1469050965
}

我的文档应该更改为：

{
  "_index" : "test",
  "_type" : "test",
  "_id" : "1212",
  "_version" : 6,
  "found" : true,
  "_source" : {
    "count" : 41,
    "list_data" : [ {
      "list_id" : 11,
      "timestamp" : 1469125397
    }, {
      "list_id" : 121,
      "timestamp" : 1469050965
    }, {
      "list_id" : 122,
      "timestamp" : 1469050965
    } ]
  }
}

如果我根据list_id = 122 执行删除，我的记录应该是这样的

{
  "_index" : "test",
  "_type" : "test",
  "_id" : "1212",
  "_version" : 7,
  "found" : true,
  "_source" : {
    "count" : 41,
    "list_data" : [ {
      "list_id" : 11,
      "timestamp" : 1469125397
    }, {
      "list_id" : 121,
      "timestamp" : 1469050965
    }]
  }
}

Answer 1

要向嵌套字段中添加新元素，您可以这样进行：

$ curl -XPOST 'localhost:9200/index/type/1212/_update?pretty' -d '
{
    "script" : "ctx._source.list_data += newElement",
    "params": {
        "newElement": {
           "list_id" : 121,
           "timestamp" : 1469050965
        }
    }
}'

要从嵌套字段列表中删除现有元素，您可以这样操作：

$ curl -XPOST 'localhost:9200/index/type/1212/_update?pretty' -d '
{
    "script" : "ctx._source.list_data.removeAll{it.list_id == remove_id}",
    "params": {
        "remove_id" : 122
    }
}'

Answer 2

我在使用最新版本的 ElasticSearch 7.9.0 时收到错误 [UpdateRequest] unknown field [params]（写此答案时 7.9.0 是最新版本），似乎语法发生了一些变化。

以下内容应该适用于较新版本的 ElasticSearch：

$ curl -XPOST 'localhost:9200/<index-name>/_update/1212'
{
  "script": {
    "source": "ctx._source.list_data.removeIf(list_item -> list_item.list_id == params.remove_id);",
    "params": {
      "remove_id": 122
    }
  }
}

Answer 3

我不知道为什么，但我发现

ctx._source.list_data.removeAll{it.list_id == remove_id}

无法工作。相反，我像这样使用removeIf：

ctx._source.list_data.removeIf{list_item -> list_item.list_id == remove_id}

list_item 可以是任意字符串。

Answer 4

对我有用的是以下link 中的说明。也许是ES的版本。