MongoDB嵌入式文档迁移为独立新文档的技术需求

针对你需要把原集合中每个文档内以数字字符串为键的嵌入式文档拆分成独立新文档的需求，这里提供两种可行方案：

方案一：使用MongoDB聚合管道（推荐，数据库端直接处理） #

利用MongoDB的聚合操作可以高效完成转换，适合数据量较大的场景，无需额外编写外部脚本。执行以下聚合命令即可将结果输出到新集合（比如命名为targetCollection）：

db.sourceCollection.aggregate([
  // 将文档的键值对转为数组，过滤掉_id和id字段
  {
    $project: {
      id: 1,
      embeddedDocs: {
        $filter: {
          input: { $objectToArray: "$$ROOT" },
          cond: {
            $and: [
              { $ne: ["$$this.k", "_id"] },
              { $ne: ["$$this.k", "id"] },
              // 判断键是否为数字字符串
              { $regexMatch: { input: "$$this.k", regex: /^\d+$/ } }
            ]
          }
        }
      }
    }
  },
  // 将数组拆分为单个文档
  { $unwind: "$embeddedDocs" },
  // 构造目标文档结构
  {
    $project: {
      _id: 0, // 不保留原文档_id，让Mongo自动生成新_id
      id: 1,
      messageId: "$embeddedDocs.k",
      createdAt: "$embeddedDocs.v.createdAt"
      // 如果嵌入式文档有其他字段，直接按此格式添加即可
    }
  },
  // 将结果写入目标集合（如果目标集合已存在，会替换；用$merge可以实现追加）
  { $out: "targetCollection" }
])

说明： #

• sourceCollection替换为你的原集合名称，targetCollection替换为你要生成的新集合名称。
• $regexMatch用于筛选数字字符串键，如果你的键格式固定是纯数字，这个判断可以保证只处理目标嵌入式文档。
• 如果需要保留原文档的其他字段，只需在$project阶段添加对应的字段即可。

方案二：使用Node.js脚本（灵活自定义逻辑） #

如果需要更灵活的处理逻辑（比如额外的数据校验、转换），可以用MongoDB驱动编写脚本完成：

const { MongoClient } = require('mongodb');

async function splitDocuments() {
  const uri = 'mongodb://localhost:27017'; // 替换为你的MongoDB连接字符串
  const client = new MongoClient(uri);

  try {
    await client.connect();
    const db = client.db('yourDatabaseName'); // 替换为你的数据库名称
    const sourceCol = db.collection('sourceCollection');
    const targetCol = db.collection('targetCollection');

    // 遍历原集合所有文档
    const cursor = sourceCol.find();
    while (await cursor.hasNext()) {
      const doc = await cursor.next();
      const { id, _id, ...rest } = doc;

      // 遍历所有非_id、非id的键
      for (const key of Object.keys(rest)) {
        // 判断键是否为数字字符串
        if (/^\d+$/.test(key)) {
          const newDoc = {
            id,
            messageId: key,
            ...rest[key] // 展开嵌入式文档的所有字段
          };
          await targetCol.insertOne(newDoc);
        }
      }
    }
    console.log('文档拆分完成');
  } finally {
    await client.close();
  }
}

splitDocuments().catch(console.error);

说明： #

• 先安装MongoDB驱动：npm install mongodb。
• 替换连接字符串、数据库名称、集合名称为你的实际信息。
• 脚本会逐个处理原文档，将符合条件的嵌入式文档转为新文档插入目标集合。

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