$bucketAuto

バージョン 8.0.2 の新機能。

Amazon DocumentDB の$bucketAuto集約ステージは、指定された式に基づいて、指定された数のバケットに入力ドキュメントを自動的にグループ化します。バケットの境界を明示的に定義する とは異なり$bucket、 は、ドキュメントがリクエストされた数のバケットに可能な限り均等に分散されるように、境界$bucketAutoを自動的に決定します。これは、事前に値の分布を知らずに固定数のグループにデータを分類する場合に便利です。

パラメータ

• groupBy (必須): グループ化する値を指定する式。

• buckets (必須): ドキュメントがグループ化されるバケットの数を指定する正の整数。入力ドキュメントとgroupBy式に応じて、実際のバケット数は指定された数未満にすることができます。

• output (オプション): 各バケットに出力する情報を指定するオブジェクト。、$sum、$avg、 などのアキュムレータ演算子を使用して$min、各バケットの集計を$max計算できます。省略すると、各バケットはデフォルトで countフィールドを出力します。

• granularity (オプション): バケットの境界に使用する優先数値系列を指定する文字列。これにより、計算された境界が標準の数値進行にスナップされます。このパラメータは、すべてのgroupBy値が数値で、いずれも でない場合にのみ使用できますNaN。有効な値は、R5、、R10、R20、R40、R80、1-2-5、、E6、E12、E24、E48E96E192、、および ですPOWERSOF2。

出力

各バケットは、バケットの境界を記述する_idオブジェクトを含む個別のドキュメントとして返されます。

• _id.min: バケットの包括的な下限。

• _id.max: バケットの上限。このバインドは、系列内の最後のバケットを除くすべてのバケットに排他的です。

例 (MongoDB シェル)

次の例は、 $bucketAutoステージを使用して販売データを価格別にバケットにグループ化する方法を示しています。

サンプルドキュメントを作成する

db.sales.insertMany([
  { item: "abc", price: 10, quantity: 2, date: new Date("2020-09-01") },
  { item: "def", price: 20, quantity: 1, date: new Date("2020-10-01") },
  { item: "ghi", price: 5, quantity: 3, date: new Date("2020-11-01") },
  { item: "jkl", price: 15, quantity: 2, date: new Date("2020-12-01") },
  { item: "mno", price: 25, quantity: 1, date: new Date("2021-01-01") }
]);

クエリの例

次のコマンドは、サンプルドキュメントを料金別に 3 つのバケットにグループ化します。

db.sales.aggregate([
  {
    $bucketAuto: {
      groupBy: "$price",
      buckets: 3,
      output: {
        "count": { $sum: 1 },
        "totalQuantity": { $sum: "$quantity" }
      }
    }
  }
])

出力

このコマンドは、以下の出力を返します。

[
  { _id: { min: 5, max: 15 }, count: 2, totalQuantity: 5 },
  { _id: { min: 15, max: 25 }, count: 2, totalQuantity: 3 },
  { _id: { min: 25, max: 25 }, count: 1, totalQuantity: 1 }
]

きめ細かなクエリの例

次の例では、計算されたバケットの境界を 2 乗にスナップするgranularityオプションを追加します。

db.sales.aggregate([
  {
    $bucketAuto: {
      groupBy: "$price",
      buckets: 2,
      granularity: "POWERSOF2",
      output: {
        "count": { $sum: 1 },
        "totalQuantity": { $sum: "$quantity" }
      }
    }
  }
])

出力

このコマンドは、以下の出力を返します。

[
  { _id: { min: 4, max: 16 }, count: 3, totalQuantity: 7 },
  { _id: { min: 16, max: 32 }, count: 2, totalQuantity: 2 }
]

コードの例

$bucketAuto コマンドを使用するコード例を表示するには、使用する言語のタブを選択します。

Node.js

const { MongoClient } = require('mongodb');

async function example() {
  const client = await MongoClient.connect('mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false');
  const db = client.db('test');
  const sales = db.collection('sales');

  const result = await sales.aggregate([
    {
      $bucketAuto: {
        groupBy: "$price",
        buckets: 3,
        output: {
          "count": { $sum: 1 },
          "totalQuantity": { $sum: "$quantity" }
        }
      }
    }
  ]).toArray();

  console.log(result);
  client.close();
}

example();

Python

from pymongo import MongoClient

def example():
    client = MongoClient('mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false')
    db = client['test']
    sales = db['sales']

    result = list(sales.aggregate([
        {
            '$bucketAuto': {
                'groupBy': '$price',
                'buckets': 3,
                'output': {
                    'count': {'$sum': 1},
                    'totalQuantity': {'$sum': '$quantity'}
                }
            }
        }
    ]))

    print(result)
    client.close()

example()