前言
ES聚合查询主要分为3类：指标聚合、桶聚合和管道聚合。
本文主要是介绍其中指标聚合的相关使用。
一、简介
指标聚合 Metrics Aggregations
如果说桶聚合主要是用来做分组的，那么指标聚合就主要是用来做数据计算的。
桶聚合和指标聚合一般都会配合使用。
类似SQL：统计订单表中每个用户的总订单金额。
select sum(t.money) from order t group by t.user
对应的DSL：
POST /order/_search
{
"size":0,
"aggs" : {
"group_user" : {
"terms" : {
"size": 5,
"field" : "user",
"order": {
"sum_money" : "desc"
}
},
"aggs": {
"sum_money": {
"sum": {"field": "money"}
}
}
}
}
}}
说明：
先采用名称为group_user的桶聚合实现根据user进行分组，然后通过子聚合sum_money对各个分组中的money进行求和。
通过order指定根据指标聚合sum_money的计算结果进行倒序排序。
通过aggs中的size限制只统计总订单金额排名前5的数据。
二、常见的指标聚合函数
三、典型使用
1.求平均值 avg
POST /exams/_search?size=0
{
"aggs": {
"avg_grade": { "avg": { "field": "grade" } }
}
}
使用脚本script：
通过script在查询时提取出运行时字段grade.corrected
POST /exams/_search?size=0
{
"runtime_mappings": {
"grade.corrected": {
"type": "double",
"script": {
"source": "emit(Math.min(100, doc['grade'].value * params.correction))",
"params": {
"correction": 1.2
}
}
}
},
"aggs": {
"avg_corrected_grade": {
"avg": {
"field": "grade.corrected"
}
}
}
}
2.最大值计算 max
POST /sales/_search?size=0
{
"aggs": {
"max_price": { "max": { "field": "price" } }
}
}
3.最大值计算 min
POST /sales/_search?size=0
{
"aggs": {
"min_price": { "min": { "field": "price" } }
}
}
4.求和 sum
POST /sales/_search?size=0
{
"query": {
"constant_score": {
"filter": {
"match": { "type": "hat" }
}
}
},
"aggs": {
"hat_prices": { "sum": { "field": "price" } }
}
}
5.速率指标聚合 Rate
速率指标聚合只能在date_histogram 或 composite聚合中使用。它计算每个存储桶中的文档或字段的速率。字段值可以从文档中的特定数值或直方图字段中提取。
GET sales/_search
{
"size": 0,
"aggs": {
"by_date": {
"date_histogram": {
"field": "date",
"calendar_interval": "month"
},
"aggs": {
"my_rate": {
"rate": {
"unit": "year"
}
}
}
}
}
}
6.唯一值数量统计 value_count
计算从聚合文档中提取的值数量的单值度量聚合。这些值可以从文档中的特定字段中提取，也可以由提供的脚本生成。通常，此聚合器将与其他单值聚合结合使用。
POST /sales/_search?size=0
{
"aggs" : {
"types_count" : { "value_count" : { "field" : "type" } }
}
}
返回：
{
...
"aggregations": {
"types_count": {
"value": 7
}
}
}总结
本文主要介绍了ES中指标聚合函数的使用。
桶聚合主要是用来做分组的，那么指标聚合就主要是用来做数据计算的。
桶聚合和指标聚合一般都会配合使用。