计算每个tag下的商品数量

按照 tags 进行分组

  1. GET /ecommerce/product/_search
  2. {
  3.   "aggs": {
  4.     "group_by_tags": {
  5.       "terms": {
  6.         "field": "tags"
  7.       }
  8.     }
  9.   }
  10. }

查询会报错

  1. {
  2.   "error": {
  3.     "root_cause": [
  4.       {
  5.         "type": "illegal_argument_exception",
  6.         "reason": "Fielddata is disabled on text fields by default. Set fielddata=true on [tags] in order to load fielddata in memory by uninverting the inverted index. Note that this can however use significant memory."
  7.       }
  8.     ],
  9.     "type": "search_phase_execution_exception",
  10.     "reason": "all shards failed",
  11.     "phase": "query",
  12.     "grouped": true,
  13.     "failed_shards": [
  14.       {
  15.         "shard": 0,
  16.         "index": "ecommerce",
  17.         "node": "-_dfHkkASWCagwSHZacgoA",
  18.         "reason": {
  19.           "type": "illegal_argument_exception",
  20.           "reason": "Fielddata is disabled on text fields by default. Set fielddata=true on [tags] in order to load fielddata in memory by uninverting the inverted index. Note that this can however use significant memory."
  21.         }
  22.       }
  23.     ],
  24.     "caused_by": {
  25.       "type": "illegal_argument_exception",
  26.       "reason": "Fielddata is disabled on text fields by default. Set fielddata=true on [tags] in order to load fielddata in memory by uninverting the inverted index. Note that this can however use significant memory."
  27.     }
  28.   },
  29.   "status": 400
  30. }

大概意思是聚合分析要提前生成正排索引，你需要提前把需要聚合对字段设置为 fielddata = true，才会生成对应对正排索引。
所以需要调用这个接口将 tags 对 fielddata 设置为 true。

  1. GET /ecommerce/_mapping/product
  2. {
  3.   "properties": {
  4.     "tags": {
  5.       "type": "text",
  6.       "fielddata": true
  7.     }
  8.   }
  9. }

再执行聚合分析，返回

  1. {
  2.   "took": 2,
  3.   "timed_out": false,
  4.   "_shards": {
  5.     "total": 5,
  6.     "successful": 5,
  7.     "failed": 0
  8.   },
  9.   "hits": {
  10.     "total": 4,
  11.     "max_score": 1,
  12.     "hits": [
  13.       {
  14.         "_index": "ecommerce",
  15.         "_type": "product",
  16.         "_id": "2",
  17.         "_score": 1,
  18.         "_source": {
  19.           "name": "jiajieshi yagao",
  20.           "desc": "youxiao fangzhu",
  21.           "price": 25,
  22.           "producer": "jiajieshi producer",
  23.           "tags": [
  24.             "fangzhu"
  25.           ]
  26.         }
  27.       },
  28.       {
  29.         "_index": "ecommerce",
  30.         "_type": "product",
  31.         "_id": "4",
  32.         "_score": 1,
  33.         "_source": {
  34.           "name": "heiren yagao",
  35.           "desc": "hei",
  36.           "price": 38,
  37.           "producer": "heiren producer",
  38.           "tags": [
  39.             "hei"
  40.           ]
  41.         }
  42.       },
  43.       {
  44.         "_index": "ecommerce",
  45.         "_type": "product",
  46.         "_id": "1",
  47.         "_score": 1,
  48.         "_source": {
  49.           "name": "gaolujie yagao",
  50.           "desc": "gaoxiao meibai",
  51.           "price": 30,
  52.           "producer": "gaolujie producer",
  53.           "tags": [
  54.             "meibai",
  55.             "fangzhu"
  56.           ]
  57.         }
  58.       },
  59.       {
  60.         "_index": "ecommerce",
  61.         "_type": "product",
  62.         "_id": "3",
  63.         "_score": 1,
  64.         "_source": {
  65.           "name": "heiren yagao",
  66.           "desc": "hei",
  67.           "price": 38,
  68.           "producer": "heiren producer",
  69.           "tags": [
  70.             "hei"
  71.           ]
  72.         }
  73.       }
  74.     ]
  75.   },
  76.   "aggregations": {
  77.     "group_by_tags": {
  78.       "doc_count_error_upper_bound": 0,
  79.       "sum_other_doc_count": 0,
  80.       "buckets": [
  81.         {
  82.           "key": "fangzhu",
  83.           "doc_count": 2
  84.         },
  85.         {
  86.           "key": "hei",
  87.           "doc_count": 2
  88.         },
  89.         {
  90.           "key": "meibai",
  91.           "doc_count": 1
  92.         }
  93.       ]
  94.     }
  95.   }
  96. }{
  97.   "took": 65,
  98.   "timed_out": false,
  99.   "_shards": {
  100.     "total": 5,
  101.     "successful": 5,
  102.     "failed": 0
  103.   },
  104.   "hits": {
  105.     "total": 4,
  106.     "max_score": 1,
  107.     "hits": [
  108.       {
  109.         "_index": "ecommerce",
  110.         "_type": "product",
  111.         "_id": "2",
  112.         "_score": 1,
  113.         "_source": {
  114.           "name": "jiajieshi yagao",
  115.           "desc": "youxiao fangzhu",
  116.           "price": 25,
  117.           "producer": "jiajieshi producer",
  118.           "tags": [
  119.             "fangzhu"
  120.           ]
  121.         }
  122.       },
  123.       {
  124.         "_index": "ecommerce",
  125.         "_type": "product",
  126.         "_id": "4",
  127.         "_score": 1,
  128.         "_source": {
  129.           "name": "heiren yagao",
  130.           "desc": "hei",
  131.           "price": 38,
  132.           "producer": "heiren producer",
  133.           "tags": [
  134.             "hei"
  135.           ]
  136.         }
  137.       },
  138.       {
  139.         "_index": "ecommerce",
  140.         "_type": "product",
  141.         "_id": "1",
  142.         "_score": 1,
  143.         "_source": {
  144.           "name": "gaolujie yagao",
  145.           "desc": "gaoxiao meibai",
  146.           "price": 30,
  147.           "producer": "gaolujie producer",
  148.           "tags": [
  149.             "meibai",
  150.             "fangzhu"
  151.           ]
  152.         }
  153.       },
  154.       {
  155.         "_index": "ecommerce",
  156.         "_type": "product",
  157.         "_id": "3",
  158.         "_score": 1,
  159.         "_source": {
  160.           "name": "heiren yagao",
  161.           "desc": "hei",
  162.           "price": 38,
  163.           "producer": "heiren producer",
  164.           "tags": [
  165.             "hei"
  166.           ]
  167.         }
  168.       }
  169.     ]
  170.   },
  171.   "aggregations": {
  172.     "group_by_tags": {
  173.       "doc_count_error_upper_bound": 0,
  174.       "sum_other_doc_count": 0,
  175.       "buckets": [
  176.         {
  177.           "key": "fangzhu",
  178.           "doc_count": 2
  179.         },
  180.         {
  181.           "key": "hei",
  182.           "doc_count": 2
  183.         },
  184.         {
  185.           "key": "meibai",
  186.           "doc_count": 1
  187.         }
  188.       ]
  189.     }
  190.   }
  191. }

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

  1. GET /ecommerce/product/_search
  2. {
  3.   "size": 0, 
  4.   "query": {
  5.     "match": {
  6.       "name": "yagao"
  7.     }
  8.   }, 
  9.   "aggs": {
  10.     "group_by_tags": {
  11.       "terms": {
  12.         "field": "tags"
  13.       }
  14.     }
  15.   }
  16. }

计算每个tag下的商品的平均价格

  1. GET /ecommerce/product/_search
  2. {
  3.   "size": 0,
  4.   "aggs": {
  5.     "group_by_tags": {
  6.       "terms": {
  7.         "field": "tags"
  8.       },
  9.       "aggs": {
  10.         "avg_price": {
  11.           "avg": {
  12.             "field": "price"
  13.           }
  14.         }
  15.       }
  16.     }
  17.   }
  18. }
  20. // 返回结果
  21. {
  22.   "took": 13,
  23.   "timed_out": false,
  24.   "_shards": {
  25.     "total": 5,
  26.     "successful": 5,
  27.     "failed": 0
  28.   },
  29.   "hits": {
  30.     "total": 4,
  31.     "max_score": 0,
  32.     "hits": []
  33.   },
  34.   "aggregations": {
  35.     "group_by_tags": {
  36.       "doc_count_error_upper_bound": 0,
  37.       "sum_other_doc_count": 0,
  38.       "buckets": [
  39.         {
  40.           "key": "fangzhu",
  41.           "doc_count": 2,
  42.           "avg_price": {
  43.             "value": 27.5
  44.           }
  45.         },
  46.         {
  47.           "key": "hei",
  48.           "doc_count": 2,
  49.           "avg_price": {
  50.             "value": 38
  51.           }
  52.         },
  53.         {
  54.           "key": "meibai",
  55.           "doc_count": 1,
  56.           "avg_price": {
  57.             "value": 30
  58.           }
  59.         }
  60.       ]
  61.     }
  62.   }
  63. }

计算每个tag下的商品的平均价格并排序

  1. GET /ecommerce/product/_search
  2. {
  3.   "size": 0,
  4.   "aggs": {
  5.     "group_by_tags": {
  6.       "terms": {
  7.         "field": "tags",
  8.         "order": {
  9.           "avg_price": "desc"
  10.         }
  11.       },
  12.       "aggs": {
  13.         "avg_price": {
  14.           "avg": {
  15.             "field": "price"
  16.           }
  17.         }
  18.       }
  19.     }
  20.   }
  21. }

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

  1. GET /ecommerce/product/_search
  2. {
  3.   "size": 0,
  4.   "aggs": {
  5.     "group_by_price": {
  6.       "range": {
  7.         "field": "price",
  8.         "ranges": [
  9.           {
  10.             "from": 10,
  11.             "to": 20
  12.           },
  13.           {
  14.             "from": 20,
  15.             "to": 30
  16.           },
  17.           {
  18.             "from": 30,
  19.             "to": 40
  20.           }
  21.         ]
  22.       },
  23.       "aggs": {
  24.         "group_by_tags": {
  25.           "terms": {
  26.             "field": "tags"
  27.           },
  28.           "aggs": {
  29.             "average_price": {
  30.               "avg": {
  31.                 "field": "price"
  32.               }
  33.             }
  34.           }
  35.         }
  36.       }
  37.     }
  38.   }
  39. }
  41. // 返回结果
  42. {
  43.   "took": 11,
  44.   "timed_out": false,
  45.   "_shards": {
  46.     "total": 5,
  47.     "successful": 5,
  48.     "failed": 0
  49.   },
  50.   "hits": {
  51.     "total": 4,
  52.     "max_score": 0,
  53.     "hits": []
  54.   },
  55.   "aggregations": {
  56.     "group_by_price": {
  57.       "buckets": [
  58.         {
  59.           "key": "10.0-20.0",
  60.           "from": 10,
  61.           "to": 20,
  62.           "doc_count": 0,
  63.           "group_by_tags": {
  64.             "doc_count_error_upper_bound": 0,
  65.             "sum_other_doc_count": 0,
  66.             "buckets": []
  67.           }
  68.         },
  69.         {
  70.           "key": "20.0-30.0",
  71.           "from": 20,
  72.           "to": 30,
  73.           "doc_count": 1,
  74.           "group_by_tags": {
  75.             "doc_count_error_upper_bound": 0,
  76.             "sum_other_doc_count": 0,
  77.             "buckets": [
  78.               {
  79.                 "key": "fangzhu",
  80.                 "doc_count": 1,
  81.                 "average_price": {
  82.                   "value": 25
  83.                 }
  84.               }
  85.             ]
  86.           }
  87.         },
  88.         {
  89.           "key": "30.0-40.0",
  90.           "from": 30,
  91.           "to": 40,
  92.           "doc_count": 3,
  93.           "group_by_tags": {
  94.             "doc_count_error_upper_bound": 0,
  95.             "sum_other_doc_count": 0,
  96.             "buckets": [
  97.               {
  98.                 "key": "hei",
  99.                 "doc_count": 2,
  100.                 "average_price": {
  101.                   "value": 38
  102.                 }
  103.               },
  104.               {
  105.                 "key": "fangzhu",
  106.                 "doc_count": 1,
  107.                 "average_price": {
  108.                   "value": 30
  109.                 }
  110.               },
  111.               {
  112.                 "key": "meibai",
  113.                 "doc_count": 1,
  114.                 "average_price": {
  115.                   "value": 30
  116.                 }
  117.               }
  118.             ]
  119.           }
  120.         }
  121.       ]
  122.     }
  123.   }
  124. }