Azure Cosmos DB API for MongoDB 3.6调用insertMany报错如何解决

错误原因 #

• 代码容错逻辑缺失：你使用var定义的intentsCopy存在变量提升，读取源集合的逻辑被包裹在try块中，且对应的catch为空完全吞掉了读取阶段的异常。如果读取源集合失败，intentsCopy会处于未赋值的undefined状态，后续调用insertMany时传入非法参数，就会触发BadValue错误。
• 异步逻辑混用问题：代码同时混用async/await和回调函数写法，数据读取和后续集合创建、写入的时序没有严格保证，可能出现写入操作触发时数据还未完成读取的情况。
• 通配符索引限制：你在新集合上创建了{"$**": 1}全字段通配符索引，如果源集合的文档存在以下情况，会触发写入时的索引校验失败：
  • 文档包含无法被通配符索引兼容的字段类型（比如超大数组、嵌套层级超出索引限制的对象）
  • 字段名包含通配符索引不支持的特殊字符
  • 复制的文档中存在重复_id值
• 写入批次超出限制：你读取数据时设置了batchSize(5000)，一次性拉取最多5000条数据后直接调用insertMany写入，MongoDB默认单次insertMany最大支持1000条操作，部分兼容MongoDB的服务对单次写入的数量、总大小限制更严格，超过限制就会报BadValue错误。

修复方案 #

1. 优化代码结构，补全错误处理 #

统一使用async/await管理异步逻辑，调整批次大小，补全异常捕获逻辑，避免空吞错误：

async function createCollection(req, res) {
  try {
    const body = req.body;
    const base = body.baseCollection;
    const newCollection = body.newCollection;
    // 提前初始化变量，避免未定义问题
    let intentsCopy = [];

    // 读取源集合数据
    const cursor = dbo
      .collection(base)
      .find()
      .batchSize(1000) // 批次大小和写入批次对齐
      .addCursorFlag("noCursorTimeout", true);
    
    await cursor.rewind();
    intentsCopy = await cursor.toArray();
    await cursor.close();

    // 创建新集合
    await dbo.createCollection(newCollection);
    // 创建通配符索引
    await dbo.createIndex(newCollection, { "$**": 1 });

    if (intentsCopy.length < 1) {
      return res.send({ success: "success", con: con });
    }

    // 分批写入，每批1000条避免超出限制
    const batchSize = 1000;
    for (let i = 0; i < intentsCopy.length; i += batchSize) {
      const batch = intentsCopy.slice(i, i + batchSize);
      await dbo.collection(newCollection).insertMany(batch);
    }

    return res.send({ success: "success", con: con });
  } catch (err) {
    // 统一错误处理
    console.error("操作失败", err);
    return res.send({ error: err.message, code: err.code });
  }
}

2. 排查索引相关问题 #

如果修改代码后仍报错，可按以下步骤处理：

• 先注释掉通配符索引的创建逻辑，测试写入是否正常，确认是否为索引导致的问题
• 如果确实需要全字段索引，可以限制通配符索引的适用字段范围，避免索引无效字段：

  // 排除不需要索引的字段，降低索引校验冲突概率
  await dbo.createIndex(newCollection, { "$**": 1 }, { wildcardProjection: { "不需要索引的字段名": 0 } });
  

• 如果不需要保留原集合的_id，可以在写入前删除所有文档的_id字段，让MongoDB自动生成新的唯一_id，避免主键冲突：

  intentsCopy = intentsCopy.map(doc => {
    delete doc._id;
    return doc;
  });
  

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