Bucket Script Aggregation(桶脚本聚合)

警告

此功能是实验性的,可能会在未来的版本中完全更改或删除。Elastic将采取最大的努力来解决任何问题,但实验功能不受SLA官方功能的支持。

父级管道聚合,它执行一个脚本,它可以在父级多桶聚合中指定度量参数执行每个桶计算。指定的度量必须是数字,脚本必须返回一个数值。

Syntax(语法)

bucket_script聚合看起来像这样:

  1. {
  2. "bucket_script": {
  3. "buckets_path": {
  4. "my_var1": "the_sum", #1
  5. "my_var2": "the_value_count"
  6. },
  7. "script": "params.my_var1 / params.my_var2"
  8. }
  9. }

| 1 | 这里,my_var1是这个桶的路径中使用脚本中的变量的名字,the_sum是路径的度量所使用的变量。 |

Table 11. bucket_script Parameters(Table 11.bucket_script参数)

参数名称 描述 是否必要 默认值
script 在这个聚合上运行的脚本。这个脚本可以是内置的,文件或索引。(详细信息,请查阅Scripting) 必须
buckets_path 脚本变量的映射,以及我们希望用于桶的变量的相关路径(相关详细信息,请参阅“buckets_path Syntax”一节) 必须
gap_policy 在数据中找到差异时应用的策略(相关详情,请参阅“Dealing with gaps in the data”一节) 可选 skip
format 应用于此聚合的输出值的格式 可选 null

以下代码计算了T恤销售额与每月销售额的比例:

  1. POST /sales/_search
  2. {
  3. "size": 0,
  4. "aggs" : {
  5. "sales_per_month" : {
  6. "date_histogram" : {
  7. "field" : "date",
  8. "interval" : "month"
  9. },
  10. "aggs": {
  11. "total_sales": {
  12. "sum": {
  13. "field": "price"
  14. }
  15. },
  16. "t-shirts": {
  17. "filter": {
  18. "term": {
  19. "type": "t-shirt"
  20. }
  21. },
  22. "aggs": {
  23. "sales": {
  24. "sum": {
  25. "field": "price"
  26. }
  27. }
  28. }
  29. },
  30. "t-shirt-percentage": {
  31. "bucket_script": {
  32. "buckets_path": {
  33. "tShirtSales": "t-shirts>sales",
  34. "totalSales": "total_sales"
  35. },
  36. "script": "params.tShirtSales / params.totalSales * 100"
  37. }
  38. }
  39. }
  40. }
  41. }
  42. }

以下是响应信息:

  1. {
  2. "took": 11,
  3. "timed_out": false,
  4. "_shards": ...,
  5. "hits": ...,
  6. "aggregations": {
  7. "sales_per_month": {
  8. "buckets": [
  9. {
  10. "key_as_string": "2015/01/01 00:00:00",
  11. "key": 1420070400000,
  12. "doc_count": 3,
  13. "total_sales": {
  14. "value": 550.0
  15. },
  16. "t-shirts": {
  17. "doc_count": 1,
  18. "sales": {
  19. "value": 200.0
  20. }
  21. },
  22. "t-shirt-percentage": {
  23. "value": 36.36363636363637
  24. }
  25. },
  26. {
  27. "key_as_string": "2015/02/01 00:00:00",
  28. "key": 1422748800000,
  29. "doc_count": 2,
  30. "total_sales": {
  31. "value": 60.0
  32. },
  33. "t-shirts": {
  34. "doc_count": 1,
  35. "sales": {
  36. "value": 10.0
  37. }
  38. },
  39. "t-shirt-percentage": {
  40. "value": 16.666666666666664
  41. }
  42. },
  43. {
  44. "key_as_string": "2015/03/01 00:00:00",
  45. "key": 1425168000000,
  46. "doc_count": 2,
  47. "total_sales": {
  48. "value": 375.0
  49. },
  50. "t-shirts": {
  51. "doc_count": 1,
  52. "sales": {
  53. "value": 175.0
  54. }
  55. },
  56. "t-shirt-percentage": {
  57. "value": 46.666666666666664
  58. }
  59. }
  60. ]
  61. }
  62. }
  63. }

原文链接 : https://www.elastic.co/guide/en/elasticsearch/reference/current/search-aggregations-pipeline-bucket-script-aggregation.html(修改该链接为官网对应的链接)

译文链接 : http://www.apache.wiki/pages/viewpage.action?pageId=10030393(修改该链接为 ApacheCN 对应的译文链接)

贡献者 : 曾少峰ApacheCNApache中文网