使用MongoDB的$graphLookup实现跨两个关联集合的递归查询问题

首先明确结论：MongoDB的$graphLookup仅支持在from参数指定的单个集合内执行递归遍历，原生不支持直接跨两个集合做递归查找。
你原写法失效的核心原因：systems集合中的signatures字段存储的是signatures集合的文档ID，本身不存在destination属性，所以递归匹配时无法找到关联的目标系统ID，最终只会返回自身文档。

不用修改现有Schema的前提下，有两种可行实现方案： #

方案1：创建预关联视图 + $graphLookup查询（推荐） #

通过MongoDB视图预先关联systems和signatures集合，为每个系统文档生成关联的目标系统ID数组，得到虚拟的中间集合，之后即可在该视图上执行标准的单集合$graphLookup递归查询。视图不会修改原有集合数据，完全符合你的Schema保留要求。

步骤1：创建预关联视图 #

db.createView("system_with_dests", "systems", [
  // 关联signatures集合拿到关联的签名文档
  {
    $lookup: {
      from: "signatures",
      localField: "signatures",
      foreignField: "_id",
      as: "signature_docs"
    }
  },
  // 提取所有关联的目标系统ID
  {
    $addFields: {
      dest_system_ids: "$signature_docs.destination"
    }
  },
  // 清理冗余字段
  { $project: { signature_docs: 0 } }
])

步骤2：对视图执行递归查询并格式化结果 #

db.system_with_dests.aggregate([
  { $match: { _id: 0 } },
  // 递归查找所有关联系统
  {
    $graphLookup: {
      from: "system_with_dests",
      startWith: "$dest_system_ids",
      connectFromField: "dest_system_ids",
      connectToField: "_id",
      maxDepth: 5,
      depthField: "depth",
      as: "all_connected_systems"
    }
  },
  // 将扁平化的关联列表转换为嵌套树形结构
  {
    $addFields: {
      connections: {
        $function: {
          body: function(rootId, nodes) {
            const nodeMap = new Map(nodes.map(n => [n._id, {...n, connections: []}]));
            nodes.forEach(node => {
              node.dest_system_ids.forEach(destId => {
                if (nodeMap.has(destId)) {
                  nodeMap.get(node._id).connections.push(nodeMap.get(destId));
                }
              });
            });
            return nodeMap.get(rootId).connections;
          },
          args: ["$_id", "$all_connected_systems"],
          lang: "js"
        }
      }
    }
  },
  // 清理冗余字段，得到最终结果
  { $project: { all_connected_systems: 0, dest_system_ids: 0, signatures: 0 } }
])

方案2：多层嵌套$lookup实现（适合递归深度固定的场景） #

如果你的业务场景中递归最大深度固定（比如你设置的maxDepth为5），可以直接编写多层嵌套的$lookup实现需求，不需要预先创建视图：

db.systems.aggregate([
  { $match: { _id: 0 } },
  // 第一层关联目标系统
  {
    $lookup: {
      from: "signatures",
      localField: "signatures",
      foreignField: "_id",
      as: "current_sigs"
    }
  },
  {
    $lookup: {
      from: "systems",
      localField: "current_sigs.destination",
      foreignField: "_id",
      as: "connections",
      pipeline: [
        // 第二层关联
        {
          $lookup: {
            from: "signatures",
            localField: "signatures",
            foreignField: "_id",
            as: "current_sigs"
          }
        },
        {
          $lookup: {
            from: "systems",
            localField: "current_sigs.destination",
            foreignField: "_id",
            as: "connections"
            // 按最大深度要求继续嵌套即可
          }
        },
        { $project: { current_sigs: 0, signatures: 0 } }
      ]
    }
  },
  { $project: { current_sigs: 0, signatures: 0 } }
])

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