Python pymongo 聚合查询

在Python中，pymongo是一个用于与MongoDB数据库交互的优秀库。聚合查询（Aggregation Pipeline）是MongoDB的强大功能之一，它允许用户对数据集合进行一系列复杂的处理步骤，最终生成一个新的结果集。Pymongo通过`aggregate()`函数支持聚合操作。

使用pymongo进行聚合查询的基本步骤包括：

1. 定义管道（Pipeline）：这是一系列包含“阶段”（Stages）的操作，每个阶段可以执行如过滤（$match）、投影（$project）、分组（$group）、排序（$sort）等操作。

from pymongo import MongoClient

# 连接到MongoDB
client = MongoClient('mongodb://localhost:27017/')
db = client['your_database']
collection = db['your_collection']

pipeline = [
    {'$match': {'field': 'some_value'}},  # 过滤文档
    {'$group': {'_id': '$another_field', 'count': {'$sum': 1}}},  # 按照字段分组并计数
    {'$sort': {'count': -1}},  # 按计数值降序排序
]

result = collection.aggregate(pipeline)

2. 执行管道：`aggregate()`方法会返回一个游标（Cursor），从中可以逐条获取聚合后的文档。