php - (Elasticsearch)如何获取所有文档的嵌套字段的最后一个元素然后执行子聚合
问题描述
我有一个名为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 查询来过滤掉这些嵌套对象
STEP 1获取 date_updated值
最高的嵌套对象
第 2
步
获得这些嵌套对象后,执行求和聚合,以便我可以为相应的“最新嵌套对象”添加soc_mm_score字段的所有值
我试过这个查询,但似乎失败了
ATTEMPT #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:我无法执行进一步的聚合
还有其他方法可以执行此操作吗?
回顾我的理想步骤:
- 访问我的eng嵌套字段
- 获取该eng嵌套字段的“最新”/最新元素(由具有最高date_updated字段值的元素指示)
- 现在,在获得那些“最近的”嵌套元素之后,对其兄弟嵌套字段进行子聚合,例如:获取eng字段的所有最新元素的soc_like_count或soc_share_count的总和
解决方案
制定了答案!
"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
"""
}
}
}