PyMongo聚合查询问题：单条数据返回及OperationFailure报错排查

1. 仅返回单条数据的原因 #

PyMongo的aggregate()方法返回的是Cursor对象，它不会自动遍历所有结果。如果你的代码是通过cursor.next()或cursor[0]这种方式取值，只会拿到第一条数据；而Mongo Shell默认会遍历整个Cursor并输出所有结果，这就是两者行为的核心差异。

2. 数组形式触发OperationFailure的原因 #

$lookup的pipeline参数要求必须是一个由聚合阶段对象组成的数组。如果你的sections_data数组里存在非对象元素（比如字符串、数字），或者数组内的聚合阶段格式错误（比如键不是合法的聚合操作符），就会触发pipeline数组的每个元素必须是对象的报错。

1. 获取全部关联数据 #

遍历PyMongo返回的Cursor对象，将其转换为列表即可获取所有结果：

from pymongo import MongoClient

client = MongoClient('mongodb://localhost:27017/')
db = client['your_db_name']
target_coll = db['your_target_collection']

# 与Mongo Shell逻辑一致的聚合管道
agg_pipeline = [
    {
        '$lookup': {
            'from': 'sections',
            'localField': 'section_id',
            'foreignField': '_id',
            'as': 'sections_data'
        }
    }
]

# 转换为列表获取所有结果
all_results = list(target_coll.aggregate(agg_pipeline))
print(f"返回数据条数: {len(all_results)}")  # 应输出2

2. 正确使用$lookup的自定义pipeline #

如果需要在$lookup中嵌套自定义聚合逻辑，确保pipeline是纯聚合阶段对象的数组，示例如下：

agg_pipeline = [
    {
        '$lookup': {
            'from': 'sections',
            'let': {'parent_id': '$_id'},
            'pipeline': [
                {'$match': {'$expr': {'$eq': ['$parent_section_id', '$$parent_id']}}},
                {'$project': {'section_name': 1, '_id': 0}}
            ],
            'as': 'sections_data'
        }
    }
]

all_results = list(target_coll.aggregate(agg_pipeline))

注意：pipeline数组内的每个元素必须是键为聚合操作符（如$match、$project）的字典，不能包含任何非对象类型的元素。

常见避坑点 #

• 不要直接用next()或索引取值，除非你明确只需要第一条数据；
• 检查$lookup的pipeline数组，确保每个元素都是合法的聚合阶段对象；
• 确认PyMongo版本与MongoDB服务器版本兼容，避免因语法差异导致的错误。

内容的提问来源于stack exchange，提问作者putta