累積和集約

親パイプライン集約で、親ヒストグラム（または日付ヒストグラム）集約内の指定されたメトリックの累積和を計算します。指定されたメトリックは数値でなければならず、囲むヒストグラムは min_doc_count を 0 に設定する必要があります（histogram 集約のデフォルト）。

構文

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

Js

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


表 58. cumulative_sum パラメータ

パラメータ名 説明 必須 デフォルト値
buckets_path 累積和を求めるバケットへのパス（詳細については buckets_path 構文 を参照） 必須
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.    "cumulative_sales": {
  17.    "cumulative_sum": {
  18.    "buckets_path": "sales"
  19.    }
  20.    }
  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.    cumulative_sales: {
  18.    cumulative_sum: {
  19.    buckets_path: 'sales'
  20.    }
  21.    }
  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.    cumulative_sales: {
  17.    cumulative_sum: {
  18.    buckets_path: "sales",
  19.    },
  20.    },
  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.    "cumulative_sales": {
  17.    "cumulative_sum": {
  18.    "buckets_path": "sales"
  19.    }
  20.    }
  21.    }
  22.    }
  23.   }
  24. }
buckets_path はこの累積和集約に sales 集約の出力を累積和に使用するよう指示します

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

コンソール-結果

  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.    "cumulative_sales": {
  17.    "value": 550.0
  18.    }
  19.    },
  20.    {
  21.    "key_as_string": "2015/02/01 00:00:00",
  22.    "key": 1422748800000,
  23.    "doc_count": 2,
  24.    "sales": {
  25.    "value": 60.0
  26.    },
  27.    "cumulative_sales": {
  28.    "value": 610.0
  29.    }
  30.    },
  31.    {
  32.    "key_as_string": "2015/03/01 00:00:00",
  33.    "key": 1425168000000,
  34.    "doc_count": 2,
  35.    "sales": {
  36.    "value": 375.0
  37.    },
  38.    "cumulative_sales": {
  39.    "value": 985.0
  40.    }
  41.    }
  42.    ]
  43.    }
  44.    }
  45. }