如何在MongoDB事务中执行含$out的聚合操作（Node.js）

由于MongoDB事务不支持包含$out或$merge阶段的聚合操作，你可以通过以下两种方案实现需求：

方案一：使用updateMany结合聚合管道（推荐） #

MongoDB 4.2及以上版本支持在更新操作中使用聚合管道，这可以直接替代原聚合+$out的逻辑，且该操作完全支持事务。

核心思路是用updateMany匹配所有文档，通过聚合管道完成updateAt字段的类型转换，无需将文档拉取到客户端：

// 假设你已经获取了事务会话session
await session.withTransaction(async () => {
  await collection.updateMany(
    {}, // 匹配集合中所有文档
    [
      {
        $set: {
          updateAt: {
            $dateFromString: {
              dateString: "$updateAt"
            }
          }
        }
      }
    ],
    { session } // 指定事务会话
  );
});

这个方案和原聚合逻辑完全等价，且性能远优于拉取文档到客户端再更新的方式。

方案二：聚合查询+批量替换（兼容旧版本） #

如果你的MongoDB版本低于4.2，无法使用聚合管道更新，可以先执行聚合查询获取转换后的文档，再在事务中通过bulkWrite批量替换原文档：

await session.withTransaction(async () => {
  // 在事务会话中执行聚合（仅查询，不带$out）
  const aggCursor = collection.aggregate([
    {
      $set: {
        updateAt: {
          $dateFromString: {
            dateString: "$updateAt"
          }
        }
      }
    }
  ], { session });

  // 将聚合结果转为数组
  const transformedDocs = await aggCursor.toArray();

  // 构建批量替换操作
  const bulkOps = transformedDocs.map(doc => ({
    replaceOne: {
      filter: { _id: doc._id }, // 按_id匹配原文档
      replacement: doc, // 用转换后的文档替换原文档
      upsert: false
    }
  }));

  // 执行批量操作
  await collection.bulkWrite(bulkOps, { session });
});

注意：该方案需要将所有文档拉取到客户端，数据量较大时会占用较多内存和网络资源，仅推荐用于旧版本MongoDB或特殊场景。

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