バケットセレクター（Bucket selector）

バケットセレクター集約

親パイプライン集約で、現在のバケットが親のマルチバケット集約に保持されるかどうかを判断するスクリプトを実行します。指定されたメトリックは数値でなければならず、スクリプトはブール値を返す必要があります。スクリプト言語が expression の場合、数値の戻り値が許可されます。この場合、0.0 は false と評価され、他のすべての値は true と評価されます。

バケットセレクター集約は、すべてのパイプライン集約と同様に、他のすべての兄弟集約の後に実行されます。これは、バケットセレクター集約を使用して応答内の返されたバケットをフィルタリングしても、集約の実行時間を節約しないことを意味します。

構文

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

Js

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

表 55. bucket_selector パラメータ


| パラメータ名 | 説明 | 必須 | デフォルト値 |
| :— | :— | :— | :— |
| script | この集約のために実行するスクリプト。スクリプトはインライン、ファイル、またはインデックス化されたものが可能です。（詳細については スクリプティング を参照） | 必須 | |
| buckets_path | 変数に使用するバケットへの関連パスを持つスクリプト変数のマップです。
（詳細については buckets_path 構文 を参照） | 必須 | |
| gap_policy | データにギャップが見つかったときに適用するポリシー（詳細については データのギャップの処理 を参照） | オプション | skip |

次のスニペットは、月の総売上が200を超えるバケットのみを保持します:

Python

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)

Ruby

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

Js

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
   }
   }
   ]
   }
   }
}