MongoDB多集合去重值求和报错：管道阶段规范需仅含一个字段

我有3个MongoDB集合，它们包含一个共同字段，但每个集合中该字段的取值不同，无法进行关联。我希望将每个集合中该字段的去重值数量相加，即distinct_value_col1 + distinct_value_col2 + distinct_value_col3。

尝试了以下代码：

db.aggregate([
  {
    '$facet': {
      'query1':
        db.col1.aggregate([
        {
        '$group': {
          _id: "$field",
          count: { $sum: 1 }
        }
        },
        {
        '$group': {
          _id: null,
          distinctCount: { $sum: 1 }
        }
        }
        ]).toArray(),
      'query2': 
        db.col2.aggregate([
          {
            '$group': {
              _id: "$field",
              count: { $sum: 1 }
            }
          },
          {
            '$group': {
              _id: null,
              distinctCount: { $sum: 1 }
            }
          }
        ]).toArray()
    }
  },
  {
    '$project': {
      total: {
        '$add': ["$query1.distinctCount", "$query2.distinctCount"]
      }
    }
  }
])

出现错误：MongoServerError: A pipeline stage specification object must contain exactly one field，求解决方法。

错误原因 #

你在$facet阶段中直接嵌入了db.col1.aggregate().toArray()这类外部执行结果，这不符合MongoDB聚合管道的语法规则。$facet的每个子管道必须是聚合阶段数组，而非预执行的结果。

最优实现方案 #

直接分别计算每个集合的去重字段数量，再在客户端层面相加即可，这种方式性能更可控：

// 计算每个集合的目标字段去重数量
const countCol1 = db.col1.aggregate([
  { $group: { _id: "$field" } }, // 按字段分组实现去重
  { $count: "distinctCount" }    // 统计分组数即去重值数量
]).toArray()[0]?.distinctCount || 0;

const countCol2 = db.col2.aggregate([
  { $group: { _id: "$field" } },
  { $count: "distinctCount" }
]).toArray()[0]?.distinctCount || 0;

const countCol3 = db.col3.aggregate([
  { $group: { _id: "$field" } },
  { $count: "distinctCount" }
]).toArray()[0]?.distinctCount || 0;

// 计算总去重值数量
const total = countCol1 + countCol2 + countCol3;
print(`总去重值数量：${total}`);

• 用?.distinctCount || 0处理空集合场景，避免undefined导致的计算错误
• 每个集合单独计算，避免跨集合数据拉取带来的性能损耗

单聚合命令实现（MongoDB 4.4+） #

如果必须用单条聚合命令完成，可使用$unionWith合并三个集合的目标字段数据后统计，但数据量大时性能会下降：

db.col1.aggregate([
  { $project: { field: 1, _id: 0 } }, // 只保留目标字段
  { $unionWith: { coll: "col2", pipeline: [{ $project: { field: 1, _id: 0 } }] } },
  { $unionWith: { coll: "col3", pipeline: [{ $project: { field: 1, _id: 0 } }] } },
  { $group: { _id: "$field" } }, // 合并后去重
  { $count: "totalDistinct" }    // 统计总去重数
])

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