如何使用PyMongo实现MongoDB Atlas跨数据库$lookup查询？

问题原因 #

你遇到的问题大概率是PyMongo版本过低，旧版本的PyMongo确实不支持$lookup的from参数传入字典格式的跨库集合定义，仅支持字符串类型的集合名。

解决方案 #

只要满足以下两个前提，就能实现跨库$lookup：

• MongoDB服务器版本 ≥ 3.6（跨库$lookup是3.6版本新增的特性）
• PyMongo版本 ≥ 3.6（对应支持该语法的驱动版本）

正确的PyMongo代码示例 #

from pymongo import MongoClient

# 建立MongoDB连接
client = MongoClient("你的MongoDB连接字符串")

# 获取源集合（sourceDB1的orders集合）
orders_collection = client["sourceDB1"]["orders"]

# 定义聚合管道，注意from参数用字典指定跨库集合
pipeline = [
    {
        "$lookup": {
            "from": {"db": "sourceDB2", "coll": "catalog"},
            "localField": "item",
            "foreignField": "sku",
            "as": "inventory_docs"
        }
    }
]

# 执行聚合查询
result = orders_collection.aggregate(pipeline)

# 遍历结果
for doc in result:
    print(doc)

注意事项 #

• 权限检查：连接MongoDB的用户必须同时拥有sourceDB1和sourceDB2的读取权限，否则会返回权限错误。
• 版本验证：可以通过以下代码检查PyMongo和MongoDB服务器版本：

  # 检查PyMongo版本
  import pymongo
  print(pymongo.__version__)
  
  # 检查MongoDB服务器版本
  server_info = client.server_info()
  print(server_info["version"])
  

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