MongoExpiredSessionError报错：GCP函数中MongoDB脚本执行异常

问题根源 #

• 添加DB.close()时，数据库异步操作（比如updateOne）还未完成就提前关闭了连接，导致会话过期触发MongoExpiredSessionError，同时未完成的写入操作失败。
• 移除DB.close()后，MongoDB客户端连接池保持活跃状态，GCP函数无法检测到所有任务已完成，因此会一直挂起无法退出。

解决方案 #

1. 确保所有异步操作完成后再处理连接 #

所有数据库操作（遍历游标、写入新集合）都是异步任务，必须等待全部完成后再执行关闭连接的操作：

• 使用await包裹游标遍历方法（如cursor.forEach()），避免提前执行后续代码。
• 如果是批量处理文档，用Promise.all()等待所有扁平化写入任务完成。

2. 复用MongoDB客户端实例（推荐GCP函数场景） #

GCP Cloud Functions支持冷启动复用外部资源，将MongoDB客户端实例放在函数外部，避免每次调用都创建/关闭连接：

let mongoClient;

async function getDb() {
  // 如果客户端已连接，直接返回数据库实例
  if (mongoClient && mongoClient.topology?.isConnected()) {
    return mongoClient.db('your-database-name');
  }
  // 首次连接或连接断开时重新创建客户端
  mongoClient = await MongoClient.connect(process.env.MONGO_URI);
  return mongoClient.db('your-database-name');
}

3. 调整脚本执行逻辑 #

修改execute和main函数，确保所有异步操作都在Promise链中完成：

async function flattenDocument(originalDoc, db) {
  // 自定义字段扁平化逻辑
  const flattened = {
    _id: originalDoc._id,
    // 示例：嵌套字段扁平化
    user_name: originalDoc.user.name,
    user_email: originalDoc.user.email,
    ...originalDoc.metadata
  };

  // 确保await写入操作完成
  await db.collection('flattened-collection').updateOne(
    { _id: originalDoc._id },
    { $set: flattened },
    { upsert: true }
  );
}

async function processCollection(db) {
  const cursor = db.collection('original-collection').find();
  
  // 等待游标遍历及所有处理完成
  await cursor.forEach(async (doc) => {
    await flattenDocument(doc, db);
  });

  // 或者用toArray + Promise.all（适合批量处理）
  // const docs = await cursor.toArray();
  // await Promise.all(docs.map(doc => flattenDocument(doc, db)));
}

exports.main = async (req, res) => {
  try {
    const db = await getDb();
    await processCollection(db);
    
    // 若不需要复用客户端，可在此关闭（确保所有操作已完成）
    // await mongoClient.close();
    
    res.status(200).send('文档扁平化处理完成');
  } catch (error) {
    console.error('处理失败:', error);
    res.status(500).send('处理失败');
  }
};

关键注意事项 #

• 不要在单个处理函数（如flattenDocument）中调用DB.close()，必须统一在所有任务完成后执行。
• GCP函数会等待main函数返回的Promise完成后终止，因此所有异步操作都要纳入main的Promise链中，避免遗漏。

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