最小バケット集約

指定されたメトリックの最小値を持つバケットを特定し、その値とバケットのキーを出力する兄弟パイプライン集約です。指定されたメトリックは数値でなければならず、兄弟集約はマルチバケット集約でなければなりません。

構文

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

Js

  1. {
  2. "min_bucket": {
  3. "buckets_path": "the_sum"
  4. }
  5. }


表 63. min_bucket パラメータ

パラメータ名 説明 必須 デフォルト値
buckets_path 最小値を見つけたいバケットへのパス(詳細については buckets_path 構文 を参照) 必須
gap_policy データにギャップが見つかった場合に適用するポリシー(詳細については データのギャップの処理 を参照) オプション skip
format 出力値のための DecimalFormat パターン。指定された場合、フォーマットされた値は集約の value_as_string プロパティに返されます オプション null

次のスニペットは、月間の sales の合計の最小値を計算します:

Python

  1. resp = client.search(
  2. index="sales",
  3. size=0,
  4. aggs={
  5. "sales_per_month": {
  6. "date_histogram": {
  7. "field": "date",
  8. "calendar_interval": "month"
  9. },
  10. "aggs": {
  11. "sales": {
  12. "sum": {
  13. "field": "price"
  14. }
  15. }
  16. }
  17. },
  18. "min_monthly_sales": {
  19. "min_bucket": {
  20. "buckets_path": "sales_per_month>sales"
  21. }
  22. }
  23. },
  24. )
  25. print(resp)

Ruby

  1. response = client.search(
  2. index: 'sales',
  3. body: {
  4. size: 0,
  5. aggregations: {
  6. sales_per_month: {
  7. date_histogram: {
  8. field: 'date',
  9. calendar_interval: 'month'
  10. },
  11. aggregations: {
  12. sales: {
  13. sum: {
  14. field: 'price'
  15. }
  16. }
  17. }
  18. },
  19. min_monthly_sales: {
  20. min_bucket: {
  21. buckets_path: 'sales_per_month>sales'
  22. }
  23. }
  24. }
  25. }
  26. )
  27. puts response

Js

  1. const response = await client.search({
  2. index: "sales",
  3. size: 0,
  4. aggs: {
  5. sales_per_month: {
  6. date_histogram: {
  7. field: "date",
  8. calendar_interval: "month",
  9. },
  10. aggs: {
  11. sales: {
  12. sum: {
  13. field: "price",
  14. },
  15. },
  16. },
  17. },
  18. min_monthly_sales: {
  19. min_bucket: {
  20. buckets_path: "sales_per_month>sales",
  21. },
  22. },
  23. },
  24. });
  25. console.log(response);

コンソール

  1. POST /sales/_search
  2. {
  3. "size": 0,
  4. "aggs": {
  5. "sales_per_month": {
  6. "date_histogram": {
  7. "field": "date",
  8. "calendar_interval": "month"
  9. },
  10. "aggs": {
  11. "sales": {
  12. "sum": {
  13. "field": "price"
  14. }
  15. }
  16. }
  17. },
  18. "min_monthly_sales": {
  19. "min_bucket": {
  20. "buckets_path": "sales_per_month>sales"
  21. }
  22. }
  23. }
  24. }
buckets_path は、この min_bucket 集約に対して、sales_per_month 日付ヒストグラム内の sales 集約の最小値を取得したいことを指示します。

次のような応答があるかもしれません:

コンソール-結果

  1. {
  2. "took": 11,
  3. "timed_out": false,
  4. "_shards": ...,
  5. "hits": ...,
  6. "aggregations": {
  7. "sales_per_month": {
  8. "buckets": [
  9. {
  10. "key_as_string": "2015/01/01 00:00:00",
  11. "key": 1420070400000,
  12. "doc_count": 3,
  13. "sales": {
  14. "value": 550.0
  15. }
  16. },
  17. {
  18. "key_as_string": "2015/02/01 00:00:00",
  19. "key": 1422748800000,
  20. "doc_count": 2,
  21. "sales": {
  22. "value": 60.0
  23. }
  24. },
  25. {
  26. "key_as_string": "2015/03/01 00:00:00",
  27. "key": 1425168000000,
  28. "doc_count": 2,
  29. "sales": {
  30. "value": 375.0
  31. }
  32. }
  33. ]
  34. },
  35. "min_monthly_sales": {
  36. "keys": ["2015/02/01 00:00:00"],
  37. "value": 60.0
  38. }
  39. }
  40. }
keys は文字列の配列であり、最小値が複数のバケットに存在する可能性があるためです