elasticsearch composite聚合
composite聚合类似于mysql的多字段group by,比如要按月以及所属门店两个维护来统计每个月的收益,如果用mysql来实现的话类似
select count(commissionamount) from xxx_table
group by timeperiod,orgId
等价的elasticsearch可以用嵌套聚合来实现:
{
"size": 0,
"aggs" : {
"my_buckets": {
"composite" : {
"size": 5,
"sources" : [
{ "date":
{ "date_histogram": { "field": "timeperiod", "interval": "1M", "order": "asc","format":"yyyy-MM" } }
},
{ "orgId": { "terms" : { "field": "orgid.keyword","order":"desc" } } }
]
},
"aggs": {
"sales": {
"sum": {
"field": "commissionamount"
}
}
}
}
}
}
上面的查询脚本的意思就是以timeperiod以及orgid.keyword两个字段作为复合聚合条件,也就是按照收益月份以及所属门店对数据进行分割,如果没有子查询的话那么仅仅返回文档数量,加上子查询后就会根据组合聚合的结果形成的桶(即Bucket),然后在每个桶内做进一步的数据聚合,即收益统计。
含有子查询结果如下图:
不含子聚合的查询结果:
还没有评论,来说两句吧...