合計バケット集約

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

構文

sum_bucket 集約は、単独で次のようになります:

Js

  1. {
  2.   "sum_bucket": {
  3.    "buckets_path": "the_sum"
  4.   }
  5. }


表 79. sum_bucket パラメータ

パラメータ名 説明 必須 デフォルト値
buckets_path 合計を求めるバケットへのパス（詳細については buckets_path 構文 を参照） 必須
gap_policy データにギャップが見つかった場合に適用するポリシー（詳細については データのギャップの処理 を参照） オプション skip
format 出力値のための DecimalFormat パターン。指定された場合、フォーマットされた値は集約の value_as_string プロパティに返されます。 オプション null

次のスニペットは、すべての合計月次 sales バケットの合計を計算します:

Python

  1. resp = client.search(
  2.    index="sales",
  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.    "sum_monthly_sales": {
  19.    "sum_bucket": {
  20.    "buckets_path": "sales_per_month>sales"
  21.    }
  22.    }
  23.    },
  24. )
  25. print(resp)

Ruby

  1. response = client.search(
  2.   index: 'sales',
  3.   body: {
  4.    size: 0,
  5.    aggregations: {
  6.    sales_per_month: {
  7.    date_histogram: {
  8.    field: 'date',
  9.    calendar_interval: 'month'
  10.    },
  11.    aggregations: {
  12.    sales: {
  13.    sum: {
  14.    field: 'price'
  15.    }
  16.    }
  17.    }
  18.    },
  19.    sum_monthly_sales: {
  20.    sum_bucket: {
  21.    buckets_path: 'sales_per_month>sales'
  22.    }
  23.    }
  24.    }
  25.   }
  26. )
  27. puts response

Js

  1. const response = await client.search({
  2.   index: "sales",
  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.    sum_monthly_sales: {
  19.    sum_bucket: {
  20.    buckets_path: "sales_per_month>sales",
  21.    },
  22.    },
  23.   },
  24. });
  25. console.log(response);

コンソール

  1. POST /sales/_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.    "sum_monthly_sales": {
  19.    "sum_bucket": {
  20.    "buckets_path": "sales_per_month>sales"
  21.    }
  22.    }
  23.   }
  24. }
buckets_path は、この sum_bucket 集約に sales 集約の合計を sales_per_month 日付ヒストグラムで求めるよう指示します。

次のような応答があるかもしれません:

コンソール-結果

  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.    "sum_monthly_sales": {
  36.    "value": 985.0
  37.    }
  38.    }
  39. }