在聚合后查找嵌套数组对象中的字段的最小值

I would like to find the minimum value of a field in a nested array object after aggregation.

我希望在聚合后找到嵌套数组对象中字段的最小值。

Data example:

[
  {
    "id": "i1",
    "version": 1,
    "entries": [
      {
        "name": "n1",
        "position": 1
      }, {
        "name": "n2",
        "position": 2
      }
    ]
  }, {
    "id": "i1"
    "version": 2,
    "entries": [
      {
        "name": "n2",
        "position": 3
      }, {
        "name": "n3",
        "position": 4
      }
    ]
  },
  {
    "id": "i2",
    "version": 1,
    "entries": [
      {
        "name": "n1",
        "position": 8
      }, {
        "name": "n2",
        "position": 7
      }
    ]
  }, {
    "id": "i2"
    "version": 2,
    "entries": [
      {
        "name": "n2",
        "position": 6
      }, {
        "name": "n3",
        "position": 5
      }
    ]
  }
]

Pseudo Query:

SELECT min(entries["n2"].position) WHERE entries.name="n2" GROUP BY id;

Expected Result:

[
  {
    "id": "i1",
    "min(position)": 2
  }, {
    "id": "i2",
    "min(position)": 6
  }
]

I can do this in code, but it's not performant, as I need to return the document sources which can be quite large.

我可以在代码中执行此操作,但它不具有高性能,因为我需要返回可能非常大的文档源。

I am thinking of denormalizing the data, but would like to first know if this request is not possible at all.

我正在考虑对数据进行非规范化,但是首先想知道这个请求是否完全不可能。

1 个解决方案

#1

You can do it by nesting several aggregations like this:

你可以通过嵌套几个聚合来做到这一点:

terms agg -> nested agg -> filter agg -> min agg

术语agg - >嵌套的agg - >过滤器agg - > min agg

To test it I set up an index:

为了测试它,我设置了一个索引:

PUT /test_index
{
   "settings": {
      "number_of_shards": 1
   },
   "mappings": {
      "doc": {
         "properties": {
            "entries": {
               "type": "nested",
               "properties": {
                  "name": {
                     "type": "string"
                  },
                  "position": {
                     "type": "long"
                  }
               }
            },
            "id": {
               "type": "string"
            },
            "version": {
               "type": "long"
            }
         }
      }
   }
}

And indexed your docs:

索引你的文档:

PUT /test_index/doc/_bulk
{"index":{"_id":1}}
{"id":"i1","version":1,"entries":[{"name":"n1","position":1},{"name":"n2","position":2}]}
{"index":{"_id":2}}
{"id":"i1","version":2,"entries":[{"name":"n2","position":3},{"name":"n3","position":4}]}
{"index":{"_id":3}}
{"id":"i2","version":1,"entries":[{"name":"n1","position":8},{"name":"n2","position":7}]}
{"index":{"_id":4}}
{"id":"i2","version":2,"entries":[{"name":"n2","position":6},{"name":"n3","position":5}]}

Here is the query:

这是查询:

POST /test_index/_search?search_type=count
{
   "aggs": {
      "id_terms": {
         "terms": {
            "field": "id"
         },
         "aggs": {
            "nested_entries": {
               "nested": {
                  "path": "entries"
               },
               "aggs": {
                  "filter_name": {
                     "filter": {
                        "term": {
                           "entries.name": "n2"
                        }
                     },
                     "aggs": {
                        "min_position": {
                           "min": {
                              "field": "position"
                           }
                        }
                     }
                  }
               }
            }
         }
      }
   }
}

and the result:

结果:

{
   "took": 2,
   "timed_out": false,
   "_shards": {
      "total": 1,
      "successful": 1,
      "failed": 0
   },
   "hits": {
      "total": 4,
      "max_score": 0,
      "hits": []
   },
   "aggregations": {
      "id_terms": {
         "doc_count_error_upper_bound": 0,
         "sum_other_doc_count": 0,
         "buckets": [
            {
               "key": "i1",
               "doc_count": 2,
               "nested_entries": {
                  "doc_count": 4,
                  "filter_name": {
                     "doc_count": 2,
                     "min_position": {
                        "value": 2,
                        "value_as_string": "2.0"
                     }
                  }
               }
            },
            {
               "key": "i2",
               "doc_count": 2,
               "nested_entries": {
                  "doc_count": 4,
                  "filter_name": {
                     "doc_count": 2,
                     "min_position": {
                        "value": 6,
                        "value_as_string": "6.0"
                     }
                  }
               }
            }
         ]
      }
   }
}

Here is the code I used all together:

这是我一起使用的代码:

http://sense.qbox.io/gist/34a013099ef07fb527d9d7cf8490ad1bbafa718b

#1