elasticsearch聚合分析

﹏ヽ暗。殇╰゛Y 2022-05-23 08:28 249阅读 0赞

# 一、前提 #

需要将文本field的fielddata属性设置为true：

PUT /ecommerce/_mapping/product
    {
      "properties": {
        "tags": {
          "type": "text",
          "fielddata": true
        }
      }
    }

其中：  
“tags”：指需要设置fielddata的field的名称，需要哪个field，就写哪个field的名称

# 二、计算每个tag下的商品数量 #

GET /ecommerce/product/_search
    {
      "aggs": {
        "my_group_by_tags": {
          "terms": { "field": "tags" }
        }
      }
    }

其中：

*  “aggs”：表示进行聚合
 *  “my\_group\_by\_tags”：聚合的名称，可以任意取
 *  “terms”：terms操作，按照指定document中的field分组，算出数量

# 三、对名称中包含yagao的商品，计算每个tag下的商品数量 #

GET /ecommerce/product/_search
    {
      "size": 0,
      "query": {
        "match": {
          "name": "yagao"
        }
      },
      "aggs": {
        "all_tags": {
          "terms": {
            "field": "tags"
          }
        }
      }
    }

其中：  
“size”：显示几个分组源数据document

# 四、先分组，再算每组的平均值，计算每个tag下的商品的平均价格 #

GET /ecommerce/product/_search
    {
        "size": 0,
        "aggs" : {
            "group_by_tags" : {
                "terms" : { "field" : "tags" },
                "aggs" : {
                    "avg_price" : {
                        "avg" : { "field" : "price" }
                    }
                }
            }
        }
    }

其中：  
“avg”：表示求平均值

# 五、计算每个tag下的商品的平均价格，并且按照平均价格降序排序 #

GET /ecommerce/product/_search
    {
        "size": 0,
        "aggs" : {
            "all_tags" : {
                "terms" : { "field" : "tags", "order": { "avg_price": "desc" } },
                "aggs" : {
                    "avg_price" : {
                        "avg" : { "field" : "price" }
                    }
                }
            }
        }
    }

其中，两个 “avg\_price” 相对应

# 六、按照指定的价格范围区间进行分组，然后在每组内再按照tag进行分组，最后再计算每组的平均价格 #

GET /ecommerce/product/_search
    {
      "size": 0,
      "aggs": {
        "group_by_price": {
          "range": {
            "field": "price",
            "ranges": [
              {
                "from": 0,
                "to": 20
              },
              {
                "from": 20,
                "to": 40
              },
              {
                "from": 40,
                "to": 50
              }
            ]
          },
          "aggs": {
            "group_by_tags": {
              "terms": {
                "field": "tags"
              },
              "aggs": {
                "average_price": {
                  "avg": {
                    "field": "price"
                  }
                }
              }
            }
          }
        }
      }
    }