Spec-Zone.ru › Elasticsearch 8
›Elasticsearch Guide [8.17] ›Агрегирования ›Агрегирования на основе конвейера

Агрегирование среднего значения по корзинам

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

Синтаксис

"avg_bucket": {
  "buckets_path": "sales_per_month>sales",
  "gap_policy": "skip",
  "format": "#,##0.00;(#,##0.00)"
}

Параметры

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

Тело ответа

value
(float) Среднее значение для указанного в buckets_path метрического показателя.
value_as_string
(строка) Отформатированное выходное значение для агрегирования. Это свойство предоставляется только в том случае, если в запросе указан format.

Пример

В следующем агрегировании avg_monthly_sales используется avg_bucket для расчета среднего значения продаж в месяц:

resp = client.search(
    size=0,
    aggs={
        "sales_per_month": {
            "date_histogram": {
                "field": "date",
                "calendar_interval": "month"
            },
            "aggs": {
                "sales": {
                    "sum": {
                        "field": "price"
                    }
                }
            }
        },
        "avg_monthly_sales": {
            "avg_bucket": {
                "buckets_path": "sales_per_month>sales",
                "gap_policy": "skip",
                "format": "#,##0.00;(#,##0.00)"
            }
        }
    },
)
print(resp)
const response = await client.search({
  size: 0,
  aggs: {
    sales_per_month: {
      date_histogram: {
        field: "date",
        calendar_interval: "month",
      },
      aggs: {
        sales: {
          sum: {
            field: "price",
          },
        },
      },
    },
    avg_monthly_sales: {
      avg_bucket: {
        buckets_path: "sales_per_month>sales",
        gap_policy: "skip",
        format: "#,##0.00;(#,##0.00)",
      },
    },
  },
});
console.log(response);
POST _search
{
  "size": 0,
  "aggs": {
    "sales_per_month": {
      "date_histogram": {
        "field": "date",
        "calendar_interval": "month"
      },
      "aggs": {
        "sales": {
          "sum": {
            "field": "price"
          }
        }
      }
    },
    "avg_monthly_sales": {
// tag::avg-bucket-agg-syntax[]               
      "avg_bucket": {
        "buckets_path": "sales_per_month>sales",
        "gap_policy": "skip",
        "format": "#,##0.00;(#,##0.00)"
      }
// end::avg-bucket-agg-syntax[]               
    }
  }
}

Начало конфигурации avg_bucket. Комментарий не входит в пример.

Конец конфигурации avg_bucket. Комментарий не входит в пример.

Запрос возвращает следующий ответ:

{
  "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
          }
        }
      ]
    },
    "avg_monthly_sales": {
      "value": 328.33333333333333,
      "value_as_string": "328.33"
    }
  }
}

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

Spec-Zone.ru

Настройки Оффлайн Что нового Помощь О нас
Spec-Zone .ru
спецификации, руководства, описания, API