› › ›

Агрегация кумулятивной суммы

Родительская агрегация поэтапно, которая вычисляет кумулятивную сумму указанного метрики в родительской агрегации гистограммы (или агрегации по дате). Указанная метрика должна быть числовой, а охватывающая гистограмма должна иметь min_doc_count установленным на значение 0 (по умолчанию для histogram агрегаций).

Синтаксис

Агрегация cumulative_sum в изоляции выглядит так:

{
  "cumulative_sum": {
    "buckets_path": "the_sum"
  }
}

Таблица 60. cumulative_sum Параметры

Имя параметра	Описание	Обязательно	Значение по умолчанию
`buckets_path`	Путь к корзинам, для которых мы хотим найти кумулятивную сумму (см. `buckets_path` Синтаксис для получения более подробной информации)	Обязательно
`format`	Шаблон DecimalFormat для выходного значения. Если указано, отформатированное значение возвращается в свойстве `value_as_string` агрегации	Необязательно	`null`

Следующий фрагмент вычисляет кумулятивную сумму общего ежемесячного sales:

resp = client.search(
    index="sales",
    size=0,
    aggs={
        "sales_per_month": {
            "date_histogram": {
                "field": "date",
                "calendar_interval": "month"
            },
            "aggs": {
                "sales": {
                    "sum": {
                        "field": "price"
                    }
                },
                "cumulative_sales": {
                    "cumulative_sum": {
                        "buckets_path": "sales"
                    }
                }
            }
        }
    },
)
print(resp)

response = client.search(
  index: 'sales',
  body: {
    size: 0,
    aggregations: {
      sales_per_month: {
        date_histogram: {
          field: 'date',
          calendar_interval: 'month'
        },
        aggregations: {
          sales: {
            sum: {
              field: 'price'
            }
          },
          cumulative_sales: {
            cumulative_sum: {
              buckets_path: 'sales'
            }
          }
        }
      }
    }
  }
)
puts response

const response = await client.search({
  index: "sales",
  size: 0,
  aggs: {
    sales_per_month: {
      date_histogram: {
        field: "date",
        calendar_interval: "month",
      },
      aggs: {
        sales: {
          sum: {
            field: "price",
          },
        },
        cumulative_sales: {
          cumulative_sum: {
            buckets_path: "sales",
          },
        },
      },
    },
  },
});
console.log(response);

POST /sales/_search
{
  "size": 0,
  "aggs": {
    "sales_per_month": {
      "date_histogram": {
        "field": "date",
        "calendar_interval": "month"
      },
      "aggs": {
        "sales": {
          "sum": {
            "field": "price"
          }
        },
        "cumulative_sales": {
          "cumulative_sum": {
            "buckets_path": "sales" 
          }
        }
      }
    }
  }
}

buckets_path указывает этой агрегации кумулятивной суммы использовать выходные данные агрегации sales для кумулятивной суммы

И следующий может быть ответом:

{
   "took": 11,
   "timed_out": false,
   "_shards": ...,
   "hits": ...,
   "aggregations": {
      "sales_per_month": {
         "buckets": [
            {
               "key_as_string": "2015/01/01 00:00:00",
               "key": 1420070400000,
               "doc_count": 3,
               "sales": {
                  "value": 550.0
               },
               "cumulative_sales": {
                  "value": 550.0
               }
            },
            {
               "key_as_string": "2015/02/01 00:00:00",
               "key": 1422748800000,
               "doc_count": 2,
               "sales": {
                  "value": 60.0
               },
               "cumulative_sales": {
                  "value": 610.0
               }
            },
            {
               "key_as_string": "2015/03/01 00:00:00",
               "key": 1425168000000,
               "doc_count": 2,
               "sales": {
                  "value": 375.0
               },
               "cumulative_sales": {
                  "value": 985.0
               }
            }
         ]
      }
   }
}

© 2023-2025 Elasticsearch
As of September 2024, Elasticsearch is available under a choice of three licenses: the Server Side Public License (SSPL), the Elastic License, or the AGPLv3 (OSI approved).
Elasticsearch and the Elasticsearch logo are trademarks of Elasticsearch B.V., registered in the U.S. and in other countries.
https://www.elastic.co/guide/en/elasticsearch/reference/8.17/search-aggregations-pipeline-cumulative-sum-aggregation.html