View a markdown version of this page

$count (akumulator) - Amazon DocumentDB

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

$count (akumulator)

Baru dari versi 8.0.1.

Gunakan $count akumulator dalam $group tahap untuk mengembalikan jumlah dokumen di setiap grup. Ia menerima objek kosong {} sebagai argumennya.

Ini berbeda dengan tahap $count pipeline, yang merupakan tahap mandiri yang menghitung semua dokumen yang melewati pipa. A $count kumulator malah menghitung dokumen dalam setiap kelompok yang diproduksi oleh$group.

Sintaksis

{ $count: {} }

Parameter

  • A $count kumulator tidak membutuhkan argumen. Ini menerima objek kosong {} dan mengembalikan jumlah dokumen di setiap grup.

Contoh (MongoDB Shell)

Contoh berikut menunjukkan cara menggunakan $count akumulator untuk menghitung jumlah produk di setiap kategori.

Buat dokumen sampel

db.products.insertMany([ { name: "Widget", category: "A" }, { name: "Gadget", category: "A" }, { name: "Doohickey", category: "B" }, { name: "Thingamajig", category: "B" }, { name: "Whatsit", category: "B" } ])

Contoh kueri

db.products.aggregate([ { $group: { _id: "$category", count: { $count: {} } } } ])

Keluaran

[ { "_id": "A", "count": 2 }, { "_id": "B", "count": 3 } ]

Contoh kode

Untuk melihat contoh kode untuk menggunakan $count akumulator, pilih tab untuk bahasa yang ingin Anda gunakan:

Node.js
const { MongoClient } = require('mongodb'); async function example() { const uri = 'mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false'; const client = new MongoClient(uri); try { await client.connect(); const db = client.db('test'); const collection = db.collection('products'); const result = await collection.aggregate([ { $group: { _id: "$category", count: { $count: {} } } } ]).toArray(); console.log(result); } catch (error) { console.error('Error:', error); } finally { await client.close(); } } example();
Python
from pymongo import MongoClient from pprint import pprint def example(): client = None try: client = MongoClient('mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false') db = client['test'] collection = db['products'] result = list(collection.aggregate([ { '$group': { '_id': '$category', 'count': { '$count': {} } } } ])) pprint(result) except Exception as e: print(f"An error occurred: {e}") finally: if client: client.close() example()