elasticsearch从入门到出门

时间:2021-12-14 22:16:04

第一个分析需求:计算每个tag下的商品数量

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

elasticsearch从入门到出门

elasticsearch从入门到出门


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

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

返回来的:

elasticsearch从入门到出门

表签tags 有2个,每个下面有1条数据

 

 第二个聚合分析的需求:对名称中包含yagao的商品,计算每个tag下的商品数量

 

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

elasticsearch从入门到出门

 

 

 
第三个聚合分析的需求:先分组,再算每组的平均值,计算每个tag下的商品的平均价格

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

 第四个数据分析需求:计算每个tag下的商品的平均价格,并且按照平均价格降序排序

 GET /ecommerce/product/_search
{
  "aggs": {
    "all_aggs": {
      "terms": {
        "field": "tags",
        "order": {
          "avg_price": "asc"
        },
        "size": 10
      },"aggs": {
        "avg_price": {
          "avg": {
            "field": "price"
          }
        }
      }
    }
  }
}

第五个数据分析需求:按照指定的价格范围区间进行分组,然后在每组内再按照tag进行分组,最后再计算每组的平均价格

GET /ecommerce/product/_search
{
  "aggs": {
    "group_by_price": {
      "range": {
        "field": "price",
        "ranges": [
          {
            "from": 10,
            "to": 21
          },{
             "from": 21,
            "to": 39
          }
        ]
      }
    }
  },"aggs": {
    "group_by_tags": {
      "terms": {
        "field": "tags",
        "size": 10
      },"aggs": {
        "avg_price": {
          "avg": {
            "field": "price"
          }
        }
      }
    }
  }
}

 

 总结下:这里调用的都是es中api

"aggs":参数

"range":范围

field:具体字段

terms分组时候要按照具体字段进行分

 

下面这条就相当于:查询所有的,然后从中选择价格段位,在这个价格段位后面有加了参数tags进行分组,在这个分组aggs中又加入了参数avg 对price进行取平均值

elasticsearch从入门到出门

 

 梦想一定要有,万一实现!