› › ›

Агрегация выбора корзин

Родительская агрегация поэтапного типа, которая выполняет скрипт, определяющий, будет ли текущая корзина сохранена в родительской агрегации множества корзин. Указанный метрический показатель должен быть числовым, а скрипт должен возвращать логическое значение. Если язык сценария – expression, то допускается числовое значение результата. В этом случае значение 0.0 будет рассматриваться как false, а все другие значения – как истинные.

Агрегация bucket_selector, как и все агрегации поэтапного типа, выполняется после всех других агрегаций-побратимов. Это означает, что использование агрегации bucket_selector для фильтрации возвращаемых корзин в ответе не экономит время выполнения агрегаций.

Синтаксис

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

{
  "bucket_selector": {
    "buckets_path": {
      "my_var1": "the_sum",                     
      "my_var2": "the_value_count"
    },
    "script": "params.my_var1 > params.my_var2"
  }
}

Здесь my_var1 – имя переменной для пути к этим корзинам, который используется в сценарии, а the_sum – путь к метрикам, используемым для этой переменной.

Таблица 57. bucket_selector Параметры

Имя параметра	Описание	Обязательно	Значение по умолчанию
`script`	Скрипт, выполняемый для этой агрегации. Скрипт может быть встроенным, файловым или индексированным. (см. Скрипты для получения более подробной информации)	Обязательно
`buckets_path`	Карта переменных скрипта и соответствующего пути к корзинам, которые мы хотим использовать для переменной (см. `buckets_path` Синтаксис для получения более подробной информации)	Обязательно
`gap_policy`	Политика, применяемая при обнаружении пробелов в данных (см. Обработка пробелов в данных для получения более подробной информации)	Необязательно	`skip`

Следующий фрагмент сохраняет только корзины, где общий объем продаж за месяц превышает 200:

resp = client.search(
    index="sales",
    size=0,
    aggs={
        "sales_per_month": {
            "date_histogram": {
                "field": "date",
                "calendar_interval": "month"
            },
            "aggs": {
                "total_sales": {
                    "sum": {
                        "field": "price"
                    }
                },
                "sales_bucket_filter": {
                    "bucket_selector": {
                        "buckets_path": {
                            "totalSales": "total_sales"
                        },
                        "script": "params.totalSales > 200"
                    }
                }
            }
        }
    },
)
print(resp)

response = client.search(
  index: 'sales',
  body: {
    size: 0,
    aggregations: {
      sales_per_month: {
        date_histogram: {
          field: 'date',
          calendar_interval: 'month'
        },
        aggregations: {
          total_sales: {
            sum: {
              field: 'price'
            }
          },
          sales_bucket_filter: {
            bucket_selector: {
              buckets_path: {
                "totalSales": 'total_sales'
              },
              script: 'params.totalSales > 200'
            }
          }
        }
      }
    }
  }
)
puts response

const response = await client.search({
  index: "sales",
  size: 0,
  aggs: {
    sales_per_month: {
      date_histogram: {
        field: "date",
        calendar_interval: "month",
      },
      aggs: {
        total_sales: {
          sum: {
            field: "price",
          },
        },
        sales_bucket_filter: {
          bucket_selector: {
            buckets_path: {
              totalSales: "total_sales",
            },
            script: "params.totalSales > 200",
          },
        },
      },
    },
  },
});
console.log(response);

POST /sales/_search
{
  "size": 0,
  "aggs": {
    "sales_per_month": {
      "date_histogram": {
        "field": "date",
        "calendar_interval": "month"
      },
      "aggs": {
        "total_sales": {
          "sum": {
            "field": "price"
          }
        },
        "sales_bucket_filter": {
          "bucket_selector": {
            "buckets_path": {
              "totalSales": "total_sales"
            },
            "script": "params.totalSales > 200"
          }
        }
      }
    }
  }
}

И вот, возможно, ответ:

{
   "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,
               "total_sales": {
                   "value": 550.0
               }
            },
            {
               "key_as_string": "2015/03/01 00:00:00",
               "key": 1425168000000,
               "doc_count": 2,
               "total_sales": {
                   "value": 375.0
               }
            }
         ]
      }
   }
}

Корзина для 2015/02/01 00:00:00 была удалена, так как общий объем продаж был меньше 200

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