1.数据聚合

    • 桶（Bucket）聚合：用来对文档做分组
      • TermAggregation：按照文档字段值分组，例如按照品牌值分组、按照国家分组
      • Date Histogram：按照日期阶梯分组，例如一周为一组，或者一月为一组
    • 度量（Metric）聚合：用以计算一些值，比如：最大值、最小值、平均值等
      • Avg：求平均值
      • Max：求最大值
      • Min：求最小值
      • Stats：同时求max、min、avg、sum等
    • 管道（pipeline）聚合：其它聚合的结果为基础做聚合

    1.1Bucket聚合语法

    1. GET /hotel/_search
    2. {
    3.   "size": 0,  // 设置size为0，结果中不包含文档，只包含聚合结果
    4.   "aggs": { // 定义聚合
    5.     "brandAgg": { //给聚合起个名字
    6.       "terms": { // 聚合的类型，按照品牌值聚合，所以选择term
    7.         "field": "brand", // 参与聚合的字段
    8.         "size": 20 // 希望获取的聚合结果数量
    9.       }
    10.     }
    11.   }
    12. }

    1.2聚合结果排序

    1. GET /hotel/_search
    2. {
    3.   "size": 0, 
    4.   "aggs": {
    5.     "brandAgg": {
    6.       "terms": {
    7.         "field": "brand",
    8.         "order": {
    9.           "_count": "asc" // 按照_count升序排列
    10.         },
    11.         "size": 20
    12.       }
    13.     }
    14.   }
    15. }

    1.3限定聚合范围

    1. GET /hotel/_search
    2. {
    3.   "query": {
    4.     "range": {
    5.       "price": {
    6.         "lte": 200 
    7.       }
    8.     }
    9.   }, 
    10.   "size": 0, 
    11.   "aggs": {
    12.     "brandAgg": {
    13.       "terms": {
    14.         "field": "brand",
    15.         "size": 20
    16.       }
    17.     }
    18.   }
    19. }

    1.4Metric聚合语法

    1. GET /hotel/_search
    2. {
    3.   "size": 0, 
    4.   "aggs": {
    5.     "brandAgg": { 
    6.       "terms": { 
    7.         "field": "brand", 
    8.         "size": 20
    9.       },
    10.       "aggs": { // 是brands聚合的子聚合，也就是分组后对每组分别计算
    11.         "score_stats": { // 聚合名称
    12.           "stats": { // 聚合类型，这里stats可以计算min、max、avg等
    13.             "field": "score" // 聚合字段，这里是score
    14.           }
    15.         }
    16.       }
    17.     }
    18.   }
    19. }

    2.RestApi实现聚合
    语法如下

    image-20210723173057733.pngimage-20210723173215728.png