zoukankan      html  css  js  c++  java
  • elasticsearch从入门到出门-04-入门的几个需求练手

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

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


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

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

    返回来的:

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

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

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

     
    第三个聚合分析的需求:先分组,再算每组的平均值,计算每个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进行取平均值

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

  • 相关阅读:
    2019/1/2
    2018/12/22
    2018/12/18
    2018/12/17
    2018/12/16
    编程总结汇总
    学习总结汇总
    第十三周学习总结--助教
    第十一周编程总结
    第10周编程总结
  • 原文地址:https://www.cnblogs.com/java-synchronized/p/7018310.html
Copyright © 2011-2022 走看看