MongoDB聚合管道存入物化视图时目标集合未创建问题求助

核心问题：聚合管道顺序错误 #

你的$merge阶段放在了$unwind和$group之前，MongoDB聚合管道是按顺序依次执行的，这意味着在执行$merge时，后续的数据拆分、分组逻辑还未运行，此时要么没有符合写入条件的输出文档，要么输出的文档不符合预期，最终导致目标集合collection_stg无法创建。

修复后的代码 #

将$merge移到聚合管道的最后，确保所有数据处理逻辑完成后再写入目标集合，同时合并重复的$match阶段优化查询效率：

updateRelations = function(creationDate) {
   db.Collection_1.aggregate( [
      // 合并两个$match阶段，减少不必要的查询步骤
      { 
        $match: {
          date: { $eq: creationDate },
          $or: [
            { objStatus: { $in: ["NEW", "UNCHANGED"] } },
            { relStatus: { $in: ["NEW", "UNCHANGED"] } },
            { subStatus: { $in: ["NEW", "UNCHANGED"] } }
          ]
        }
      },
      {
        $graphLookup: {
          from: "SourceRelationship_DEV", // 注意此处与原管道的from不一致，确认是否为笔误
          startWith: "$predicate",
          connectFromField: "subject",
          connectToField: "predicate",
          as: "relatonship",
          maxDepth: 0,
        },
      },
      { 
        $unwind: {
          path: "$relatonship",
          // 添加该配置过滤无关联数据的文档，避免无效数据进入分组阶段
          preserveNullAndEmptyArrays: false
        },
      },
      {
        $group: {
          _id: "$relatonship.subject",
          relation: {
            $addToSet: {
              predicate: "$relatonship.predicate",
              object: "$relatonship.object",
              startDate: "$relatonship.startDate"
            },
          },
        },
      },
      // 将$merge移至最后，确保所有数据处理完成后写入目标集合
      { 
        $merge: { 
          into: "collection_stg", 
          on: "_id", 
          whenMatched: "replace", 
          whenNotMatched: "insert" 
        } 
      }
   ] );
};

额外检查点 #

1. $graphLookup的from参数：原管道中from为"Collection_1"，新代码中改为"SourceRelationship_DEV"，确认是否为有意修改，若为笔误会导致关联数据错误。
2. maxDepth: 0的替代方案：maxDepth:0仅匹配直接关联的节点（即startWith的值等于connectToField的文档），这种场景下用普通$lookup替代$graphLookup性能更优：

   {
     $lookup: {
       from: "SourceRelationship_DEV",
       localField: "predicate",
       foreignField: "predicate",
       as: "relatonship"
     }
   }
   

3. 数据匹配验证：执行函数前先单独运行$match阶段，确认有符合条件的文档：

   db.Collection_1.find({
     date: { $eq: creationDate },
     $or: [
       { objStatus: { $in: ["NEW", "UNCHANGED"] } },
       { relStatus: { $in: ["NEW", "UNCHANGED"] } },
       { subStatus: { $in: ["NEW", "UNCHANGED"] } }
     ]
   }).count()
   

   如果返回0，说明没有匹配的数据，自然不会创建目标集合。

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