MongoExpiredSessionError：while循环中无法使用已结束的会话

问题场景 #

使用Node.js和MongoDB开发时，查询一批记录后，为每条记录调用外部API获取结果，再通过updateOne为记录新增字段赋值，执行updateOne时触发MongoExpiredSessionError错误。

错误原因 #

1. 默认会话超时：MongoDB的默认会话有超时限制，当查询记录后调用外部API耗时较长，执行updateOne时，初始查询使用的会话已过期。
2. 异步操作未等待：原代码中updateOne未加await，导致异步操作堆积，加剧会话资源耗尽或超时问题。

解决方案 #

1. 显式创建并复用会话 #

手动创建MongoDB会话，让查询和更新操作共享同一个会话，避免默认会话提前过期：

const collection = database.collection("test");

async function run() {
  // 显式启动会话
  const session = await database.startSession();
  try {
    // 绑定会话到查询操作
    let records = [];
    const cursor = collection.find(filter).limit(num).session(session);
    await cursor.forEach(doc => records.push(doc));

    while (records.length) {
      const record = records.pop();
      try {
        // 调用外部API（需确保是await的异步操作）
        const value = await callYourExternalApi(record);
        // 绑定会话到updateOne，并等待操作完成
        await collection.updateOne(
          { _id: record._id },
          { $set: { "NewField": value }},
          { session: session }
        );
      } catch (error) {
        console.log(`更新记录${record._id}失败:`, error);
      }
    }
  } catch (error) {
    console.log("流程执行出错:", error);
  } finally {
    // 关闭会话
    await session.endSession();
  }
}

2. 确保所有异步操作使用await #

原代码中updateOne未添加await，会导致操作无顺序执行，既无法捕获错误，还会加速会话资源消耗。必须为updateOne和外部API调用添加await，保证操作顺序执行。

3. 调整会话超时时间（可选） #

如果业务场景确实需要较长时间处理单条记录，可以在MongoDB连接配置中调整会话超时时间，但不推荐过度依赖此方法，优先通过显式会话管理解决问题：

// 连接MongoDB时配置会话超时
const client = new MongoClient(uri, {
  serverApi: ServerApiVersion.v1,
  sessionTimeoutMS: 3600000 // 设置为1小时，根据业务调整
});

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