平均バケット集計

兄弟パイプライン集計で、兄弟集計内の指定されたメトリックの平均値を計算します。指定されたメトリックは数値でなければならず、兄弟集計はマルチバケット集計でなければなりません。

構文

Js

  1. "avg_bucket": {
  2. "buckets_path": "sales_per_month>sales",
  3. "gap_policy": "skip",
  4. "format": "#,##0.00;(#,##0.00)"
  5. }

パラメータ

  • buckets_path
  • (必須、文字列) 平均を取るバケットへのパス。構文については、buckets_path 構文を参照してください。
  • gap_policy
  • (オプション、文字列) データにギャップが見つかった場合に適用するポリシー。有効な値については、データのギャップの処理を参照してください。デフォルトは skip です。
  • format
  • (オプション、文字列) 出力値のためのDecimalFormatパターン。指定された場合、フォーマットされた値は集計の value_as_string プロパティに返されます。

レスポンスボディ

  • value
  • (float) buckets_path で指定されたメトリックの平均値。
  • value_as_string
  • (string) 集計のフォーマットされた出力値。このプロパティは、リクエストで format が指定された場合にのみ提供されます。

次の avg_monthly_sales 集計は、avg_bucket を使用して月ごとの平均売上を計算します:

Python

  1. resp = client.search(
  2. size=0,
  3. aggs={
  4. "sales_per_month": {
  5. "date_histogram": {
  6. "field": "date",
  7. "calendar_interval": "month"
  8. },
  9. "aggs": {
  10. "sales": {
  11. "sum": {
  12. "field": "price"
  13. }
  14. }
  15. }
  16. },
  17. "avg_monthly_sales": {
  18. "avg_bucket": {
  19. "buckets_path": "sales_per_month>sales",
  20. "gap_policy": "skip",
  21. "format": "#,##0.00;(#,##0.00)"
  22. }
  23. }
  24. },
  25. )
  26. print(resp)

Js

  1. const response = await client.search({
  2. size: 0,
  3. aggs: {
  4. sales_per_month: {
  5. date_histogram: {
  6. field: "date",
  7. calendar_interval: "month",
  8. },
  9. aggs: {
  10. sales: {
  11. sum: {
  12. field: "price",
  13. },
  14. },
  15. },
  16. },
  17. avg_monthly_sales: {
  18. avg_bucket: {
  19. buckets_path: "sales_per_month>sales",
  20. gap_policy: "skip",
  21. format: "#,##0.00;(#,##0.00)",
  22. },
  23. },
  24. },
  25. });
  26. console.log(response);

コンソール

  1. POST _search
  2. {
  3. "size": 0,
  4. "aggs": {
  5. "sales_per_month": {
  6. "date_histogram": {
  7. "field": "date",
  8. "calendar_interval": "month"
  9. },
  10. "aggs": {
  11. "sales": {
  12. "sum": {
  13. "field": "price"
  14. }
  15. }
  16. }
  17. },
  18. "avg_monthly_sales": {
  19. // tag::avg-bucket-agg-syntax[]
  20. "avg_bucket": {
  21. "buckets_path": "sales_per_month>sales",
  22. "gap_policy": "skip",
  23. "format": "#,##0.00;(#,##0.00)"
  24. }
  25. // end::avg-bucket-agg-syntax[]
  26. }
  27. }
  28. }
avg_bucket 構成の開始。コメントは例の一部ではありません。
avg_bucket 構成の終了。コメントは例の一部ではありません。

リクエストは次のレスポンスを返します:

コンソール-結果

  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. "sales": {
  14. "value": 550.0
  15. }
  16. },
  17. {
  18. "key_as_string": "2015/02/01 00:00:00",
  19. "key": 1422748800000,
  20. "doc_count": 2,
  21. "sales": {
  22. "value": 60.0
  23. }
  24. },
  25. {
  26. "key_as_string": "2015/03/01 00:00:00",
  27. "key": 1425168000000,
  28. "doc_count": 2,
  29. "sales": {
  30. "value": 375.0
  31. }
  32. }
  33. ]
  34. },
  35. "avg_monthly_sales": {
  36. "value": 328.33333333333333,
  37. "value_as_string": "328.33"
  38. }
  39. }
  40. }