（Elasticsearch）如何获取所有文档的嵌套字段的最后一个元素，然后执行子聚合

Question

我有一个名为socialmedia的索引，并试图用这个名为eng的字段创建查询（省略了一些不必要的字段）

"id" : "1",
"eng": 
[
{
  "soc_mm_score" : "3",
  "date_updated" : "1520969306",
},
{
  "soc_mm_score" : "1",
  "date_updated" : "1520972191",
},
{
  "soc_mm_score" : "4",
  "date_updated" : "1520937222",
}
]

我从这个索引中有很多文档，其中包含eng嵌套字段，该字段也包含很多“子对象”

现在，我的主要目标是，我应该制定什么样的Elasticsearch查询来过滤这些嵌套对象

步骤1
获取具有最高date_updated值的嵌套对象

步骤2
在获得这些嵌套对象之后，执行一个总和聚合，这样我就可以为相应的“最新嵌套对象”添加soc_mm_score字段的所有值。

我试过这个查询，但似乎失败了

尝试#1（我使用的是elasticsearch-php API，所以请相信我的查询使用的是这种格式）

'aggs' => [
    'ENG' => [
        'nested' => [
            'path' => 'eng'
        ],
        'aggs' => [
            'FILTER' => [
                'filter' => [
                    'bool' => [
                        'must' => [
                            [
                                // I'm thinking of using max aggregation here
                            ]
                        ]
                    ]
                ]
            ]
            'LATEST' => [
                'top_hits' => [
                    'size' => 1,
                    'sort' => [
                        'eng.date_updated' => [
                            'order' => 'desc'
                        ]
                    ]
                ]
            ]
        ]
    ]
]

Pro/S：它正在返回正确的嵌套对象CON/S：我无法执行进一步的聚合

我还有其他的方法可以执行这个吗？

回顾我的理想步骤：

1. 访问我的eng嵌套字段
2. 获取该eng嵌套字段的“最新”/最近元素（由date_updated字段值最高的元素指示）
3. 现在，在获得这些“最近的”嵌套元素之后，为其同级嵌套字段进行子聚合，例如：获取eng字段所有最近元素的soc_like_count或soc_share_count的总和

Answer 1

制定了一个答案！

"aggs":{
        "LATEST": {
            "scripted_metric": {
                "init_script" : """
                  state.te = []; 
                  state.g = 0;
                  state.d = 0;
                  state.a = 0;
                """, 
                "map_script" : """
                  if(state.d != doc['_id'].value){
                      state.d = doc['_id'].value;
                      state.te.add(state.a);
                      state.g = 0;
                      state.a = 0;
                  } 
                  if(state.g < doc['eng.date_updated'].value){ 
                    state.g = doc['eng.date_updated'].value; 
                    state.a = doc['eng.soc_te_score'].value;
                  }
                  """,
                "combine_script" : """
                    state.te.add(state.a);
                    double count = 0; 
                    for (t in state.te) { 
                      count += t 
                    }

                    return count
                  """,
                "reduce_script" : """
                    double count = 0; 
                    for (a in states) { 
                      count += a 
                    }

                    return count
                """
            }
        }
      }