新手教学系列——MongoDB聚合查询的进阶用法

引言

MongoDB的聚合查询是其最强大的功能之一。无论是汇总、平均值、计数等标准操作，还是处理复杂的数据集合，MongoDB的聚合框架都能提供高效且灵活的解决方案。本文将通过几个实例，详细讲解如何在实际项目中使用MongoDB进行聚合查询。

标准应用：汇总、平均值、计数等

在日常的数据处理工作中，汇总、计算平均值和计数等操作非常常见。下面，我们通过一个具体实例，展示如何使用MongoDB进行这些基本的聚合操作。

实例一：计算每个商品的平均评分

假设我们有一个包含商品评论的集合，每条评论包含商品ID、用户ID和评分。我们希望计算每个商品的平均评分。

from pymongo import MongoClient
 
# 连接MongoDB
client = MongoClient('mongodb://localhost:27017/')
db = client['shop']
collection = db['reviews']
 
# 聚合管道
pipeline = [
    {
        '$group': {
            '_id': '$product_id',  # 按商品ID分组
            'average_rating': {'$avg': '$rating'},  # 计算平均评分
            'review_count'