MongoDB嵌套数组查询问题：如何返回指定子文档而非完整文档

嘿，我来帮你搞定这个MongoDB查询的问题～ 先给你理清楚两个核心点：为啥默认返回完整文档，以及怎么实现你要的子文档返回。

一、为什么查询返回完整文档而非目标子字典？ #

MongoDB的默认查询逻辑就是这样的：当你用普通的find()查询时，只要文档满足查询条件（比如readings.SS1="7.80"），就会返回整个匹配的文档，而不会自动提取数组里的单个元素。这是因为一个文档里可能有多个数组元素满足条件，MongoDB不确定你要哪一个，所以默认返回全文档。

要只返回数组中符合条件的子文档，你需要用到投影（Projection）或者聚合管道（Aggregation Pipeline），具体看你的需求复杂度。

二、如何返回指定的readings子文档？ #

场景1：匹配单个数组元素（比如readings.SS1="7.80"） #

如果你的需求是返回文档中第一个匹配SS1="7.80"的readings子元素，可以用$elemMatch做投影：

from pymongo import MongoClient

client = MongoClient('mongodb://localhost:27017/')
db = client['your_database']
collection = db['your_collection']

# 查询并投影匹配的readings子文档
result = collection.find(
    {"readings.SS1": "7.80"},
    {"readings": {"$elemMatch": {"SS1": "7.80"}}, "_id": 0}
)

for doc in result:
    print(doc['readings'][0])  # 因为$elemMatch返回的是包含单个元素的数组，所以取索引0

但这个方法有个局限：如果一个文档里有多个readings元素满足SS1="7.80"，它只会返回第一个匹配的。

场景2：返回所有匹配条件的readings子文档 #

这种情况用聚合管道更合适，步骤是：

1. $match：先筛选出符合外层条件的文档（比如包含目标SS1的文档）
2. $unwind：把readings数组拆分成单个文档
3. $match：再次筛选出符合条件的单个readings子文档
4. $replaceRoot：把子文档变成根文档（可选，让输出更简洁）

示例代码：

pipeline = [
    # 第一步：筛选出包含readings.SS1="7.80"的文档
    {"$match": {"readings.SS1": "7.80"}},
    # 第二步：拆分readings数组为单个文档
    {"$unwind": "$readings"},
    # 第三步：筛选出符合条件的readings子文档
    {"$match": {"readings.SS1": "7.80"}},
    # 第四步（可选）：把readings子文档作为根文档返回
    {"$replaceRoot": {"newRoot": "$readings"}}
]

result = collection.aggregate(pipeline)
for reading in result:
    print(reading)

这样就能得到所有符合条件的readings子文档了。

三、实现多条件查询：info.OP="157.138" 且 15000000<timestamp<15500000 #

这个需求需要同时匹配外层的info.OP和readings数组里的timestamp范围，同样用聚合管道来实现最稳妥：

pipeline = [
    # 第一步：先筛选出info.OP符合条件的文档（缩小范围，提升效率）
    {"$match": {"info.OP": "157.138"}},
    # 第二步：拆分readings数组
    {"$unwind": "$readings"},
    # 第三步：同时匹配timestamp的范围条件
    {"$match": {
        "readings.timestamp": {"$gt": 15000000, "$lt": 15500000}
    }},
    # 可选：返回子文档作为根
    {"$replaceRoot": {"newRoot": "$readings"}}
]

result = collection.aggregate(pipeline)
for reading in result:
    print(reading)

如果还需要保留外层的info信息（比如同时返回info和符合条件的readings），可以调整管道，比如用$group把符合条件的readings重新聚合：

pipeline = [
    {"$match": {"info.OP": "157.138"}},
    {"$unwind": "$readings"},
    {"$match": {
        "readings.timestamp": {"$gt": 15000000, "$lt": 15500000}
    }},
    {"$group": {
        "_id": "$_id",
        "info": {"$first": "$info"},
        "matched_readings": {"$push": "$readings"}
    }}
]

result = collection.aggregate(pipeline)
for doc in result:
    print(f"Info: {doc['info']}")
    print(f"Matched readings: {doc['matched_readings']}")

这样就能同时得到外层info和所有符合条件的readings子文档了。

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