如何使用PyMongo查询MongoDB文档内满足指定条件的数组元素？

首先得说，你之前的代码里用find_one配合$投影的问题在于：$这个投影操作符只会返回数组中第一个匹配$elemMatch条件的元素，所以如果message_logs里有多个符合des: dev_id的日志条目，你只能拿到第一个，这肯定不是你想要的结果对吧？

下面给你两个实用的解决方案，适配你使用Python3.6和最新MongoDB的场景：

方案1：使用聚合框架（灵活通用） #

聚合管道可以一步步筛选、处理数据，适合复杂的数组操作：

def get_target_message_logs(module_id, dev_id):
    try:
        pipeline = [
            # 第一步：先定位到对应module_id的文档，缩小处理范围
            {"$match": {"info.id": module_id}},
            # 第二步：把message_logs数组拆分成单个文档，方便后续筛选
            {"$unwind": "$message_logs"},
            # 第三步：筛选出des等于dev_id的日志条目
            {"$match": {"message_logs.des": dev_id}},
            # 第四步：只保留需要的message_logs字段，去掉默认的_id
            {"$project": {"message_logs": 1, "_id": 0}},
            # 第五步：把筛选后的日志重新组合成数组（可选，根据你的返回格式需求）
            {"$group": {"_id": None, "matched_logs": {"$push": "$message_logs"}}}
        ]
        # 执行聚合并获取结果
        result = db.modules.aggregate(pipeline).next()
        # 如果有结果就返回匹配的日志数组，否则返回空列表
        return result.get("matched_logs", [])
    except StopIteration:
        # 没有找到对应module_id的文档时返回空列表
        return []
    except Exception as e:
        # 其他异常按需处理，这里返回你原来的提示
        return "Unconfigured dev..."

方案2：使用$filter投影（更简洁高效） #

MongoDB 3.2及以上版本支持$filter操作符，直接在投影阶段过滤数组，不用拆分重组，性能更好：

def get_target_message_logs(module_id, dev_id):
    try:
        # 先筛选出对应module_id的文档
        filter_param = {"info.id": module_id}
        # 用$filter在投影里直接过滤message_logs数组
        proj_param = {
            "_id": 0,
            "matched_logs": {
                "$filter": {
                    "input": "$message_logs",  # 要过滤的数组字段
                    "as": "log",               # 数组元素的别名
                    "cond": {"$eq": ["$$log.des", dev_id]}  # 匹配条件
                }
            }
        }
        result = db.modules.find_one(filter_param, projection=proj_param)
        # 返回过滤后的日志数组，没有结果就返回空列表
        return result.get("matched_logs", []) if result else []
    except Exception:
        return "Unconfigured dev..."

这个方案更推荐，因为它不需要拆分数组，直接在原文档上过滤数组元素，代码更简洁，执行效率也更高。

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