Mongoose异步函数执行Quote.insertMany后出现未处理Promise拒绝错误的排查与解决

咱们来一步步拆解你这段代码里的问题，以及怎么解决这些Promise拒绝和Mongo会话错误：

核心问题点 #

• 异步操作未正确等待，混合回调与Promise：
  你在Author.findOne里用了传统回调模式，但没有把它转换成Promise，这导致Promise.all里的元素并不是真正的Promise对象。而且author.save()是异步方法，你直接调用却没等待它完成，也没返回它的Promise，这会导致这些保存操作还在后台跑的时候，后续的关闭连接代码就已经执行了。
• 错误处理无效：next()不存在：
  这个自执行异步函数里并没有Express的next中间件，你在错误分支里调用next(err)完全无效，反而会导致未捕获的错误。
• 数据库连接提前关闭：
  你在await Quote.insertMany(...)之后立刻调用db.close()，但此时Promise.all里的所有作者更新操作大概率还没完成，直接关闭连接会导致Mongo会话提前终止，触发Cannot use a session that has ended错误。
• async/await与.then/.catch混合使用导致逻辑混乱：既然已经用了async函数，统一用try/catch处理错误会比混合写法更清晰，也更容易排查问题。

修复后的完整代码 #

(async function() {
  try {
    // 先等待数据库连接建立完成，确保后续操作有可用会话
    await db.connect();

    // 用await直接获取insertMany的结果，替代.then链式调用
    const insertedQuotes = await Quote.insertMany(quotes);

    // 遍历所有插入的quote，用async函数包裹每个操作，生成Promise数组
    await Promise.all(insertedQuotes.map(async (quote) => {
      try {
        // Mongoose方法不传回调会返回Promise，用await获取作者数据
        const author = await Author.findOne({ id: quote.authorid });
        if (author) {
          author.quotes.push(quote._id);
          // 等待作者保存操作完成，确保更新落库
          await author.save();
          console.log("SAVED");
        }
      } catch (authorErr) {
        // 单独处理单个作者更新的错误，不影响其他操作
        console.error(`Failed to update author for quote ${quote._id}:`, authorErr);
      }
    }));

    console.log("Closing connection");
    // 所有数据库操作完成后再关闭连接
    await db.close();
  } catch (topLevelErr) {
    // 处理顶层错误，比如连接失败、批量插入quote失败等
    console.error("Critical error occurred:", topLevelErr);
    // 即使出错也要确保连接关闭，避免资源泄漏
    await db.close();
  }
})();

关键修复细节说明 #

1. 统一异步处理风格：全程使用async/await+try/catch，抛弃混合.then/.catch的写法，让异步逻辑更直观。
2. 等待所有异步操作完成：
   • 等待db.connect()建立连接后再执行后续操作；
   • 将Author.findOne转为Promise形式，用await获取结果；
   • 等待author.save()完成，保证更新操作执行完毕；
   • 用await Promise.all(...)等待所有作者更新操作全部完成后，再执行关闭连接的逻辑。
3. 修复错误处理逻辑：移除无效的next()调用，换成在catch块里记录错误，同时给单个作者操作添加局部catch，避免单个失败导致整个批量操作终止。
4. 保证连接最后关闭：无论操作成功还是失败，都在所有异步流程结束后才关闭数据库连接，彻底解决会话提前结束的问题。

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