Node.js/TypeScript中MongoDB bulkWrite批量更新失效问题求助

forEach不会等待内部的异步函数执行完成——循环会直接遍历完所有users，随后立刻执行CustomerModel.bulkWrite(operations)，此时operations数组还未被填充（或仅部分填充），导致批量更新没有作用。

方法1：使用for...of循环（串行处理） #

for...of能正确等待每个异步迭代完成，确保所有更新操作都被添加到operations数组后，再执行批量写入。

async function main() {
  try {
    const operations: any[] = [];
    // 替换forEach为for...of
    for (const user of users) {
      const custId = decrypt(user.id);
      const customer = await CustomerModel.findOne({ custId: custId });
      if (customer) {
        let { setting } = customer;
        setting = {
          ...setting,
          description: user.description
        };
        const doc = {
          updateOne: {
            filter: { custId: custId },
            update: { location: 'USA', ...setting }
          }
        };
        operations.push(doc);
      }
    }
    console.log(operations);
    const res = await CustomerModel.bulkWrite(operations);
    console.log('批量更新结果:', res);
  } catch (error) {
    console.error(error);
  }
}
main();

方法2：使用Promise.all（并行处理，效率更高） #

如果用户数量较多，并行处理能大幅提升效率。将每个异步逻辑包装成Promise，用Promise.all等待所有任务完成，同时收集有效的更新操作。

async function main() {
  try {
    // 生成所有异步任务的Promise数组
    const operationPromises = users.map(async (user) => {
      const custId = decrypt(user.id);
      const customer = await CustomerModel.findOne({ custId: custId });
      if (customer) {
        let { setting } = customer;
        setting = {
          ...setting,
          description: user.description
        };
        return {
          updateOne: {
            filter: { custId: custId },
            update: { location: 'USA', ...setting }
          }
        };
      }
      // 未找到customer时返回null，后续过滤掉无效项
      return null;
    });

    // 等待所有Promise完成，过滤空值
    const operations = (await Promise.all(operationPromises)).filter(Boolean);
    console.log(operations);
    const res = await CustomerModel.bulkWrite(operations);
    console.log('批量更新结果:', res);
  } catch (error) {
    console.error(error);
  }
}
main();

• 避免使用any类型，给operations定义明确的类型：

  import { BulkWriteOperation } from 'mongoose';
  const operations: BulkWriteOperation<Customer>[] = [];
  

• 若decrypt是异步函数，记得添加await关键字；
• 可通过bulkWrite返回的结果，查看成功/失败的操作数量，做进一步的错误处理。

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