› › ›

Агрегирование максимального значения в корзинах

Агрегирование по конвейеру, которое определяет корзину(ы) с максимальным значением заданного метрического показателя в связанном агрегировании и выводит как значение, так и ключ(и) корзины(ы). Заданный метрический показатель должен быть числовым, а связанное агрегирование должно быть агрегированием по нескольким корзинам.

Синтаксис

Агрегирование max_bucket выглядит следующим образом:

{
  "max_bucket": {
    "buckets_path": "the_sum"
  }
}

Таблица 64. max_bucket Параметры

Имя параметра	Описание	Требуется	Значение по умолчанию
`buckets_path`	Путь к корзинам, для которых требуется найти максимальное значение (см. `buckets_path` Синтаксис для получения более подробной информации)	Требуется
`gap_policy`	Политика, применяемая при обнаружении пробелов в данных (см. Обработка пробелов в данных для получения более подробной информации)	Необязательно	`skip`
`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"
                    }
                }
            }
        },
        "max_monthly_sales": {
            "max_bucket": {
                "buckets_path": "sales_per_month>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'
            }
          }
        }
      },
      max_monthly_sales: {
        max_bucket: {
          buckets_path: 'sales_per_month>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",
          },
        },
      },
    },
    max_monthly_sales: {
      max_bucket: {
        buckets_path: "sales_per_month>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"
          }
        }
      }
    },
    "max_monthly_sales": {
      "max_bucket": {
        "buckets_path": "sales_per_month>sales" 
      }
    }
  }
}

buckets_path указывает этому агрегированию max_bucket, что нам требуется максимальное значение агрегирования sales в гистограмме дат sales_per_month.

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

{
   "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
               }
            },
            {
               "key_as_string": "2015/02/01 00:00:00",
               "key": 1422748800000,
               "doc_count": 2,
               "sales": {
                  "value": 60.0
               }
            },
            {
               "key_as_string": "2015/03/01 00:00:00",
               "key": 1425168000000,
               "doc_count": 2,
               "sales": {
                  "value": 375.0
               }
            }
         ]
      },
      "max_monthly_sales": {
          "keys": ["2015/01/01 00:00:00"], 
          "value": 550.0
      }
   }
}

keys представляет собой массив строк, поскольку максимальное значение может присутствовать в нескольких корзинах

© 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-max-bucket-aggregation.html