MongoDB Atlas函数写入GCS失败问题排查

问题根源 #

你遇到的错误是由于MongoDB Atlas Cloud Function尝试序列化save()方法返回的可写流对象导致的。storage.bucket(bucketName).file(destFilename).save(contents)返回的是一个Promise<fs.WriteStream>，当你直接返回这个Promise的结果时，Atlas函数运行环境会试图将复杂的Stream对象序列化为JSON，但Stream包含大量内部状态和循环引用，无法完成正常序列化，从而抛出你看到的冗长错误。

解决方案 #

修改代码，不直接返回Stream对象，而是等待上传完成后返回简单的状态信息，并添加错误处理以便排查问题：

exports = async function(changeEvent) {
  const { Storage } = require('@google-cloud/storage');
  const storage = new Storage({
    projectId: '<project-id>',
    credentials: JSON.parse(context.values.get('GOOGLE_APPLICATION_CREDENTIALS'))
  });
  const destFilename = '<filename>';
  const bucketName = '<bucket-name>';
  const contents = 'these are my contents';
  
  try {
    // 等待上传操作完成，不返回Stream对象
    await storage.bucket(bucketName).file(destFilename).save(contents);
    return { status: 'success', message: '文件已成功上传至GCS' };
  } catch (err) {
    console.error('上传失败:', err);
    return { status: 'error', message: err.message };
  }
}

关键说明 #

• 移除直接返回save()结果的逻辑，改为在await后返回自定义的简单JSON对象，避免序列化复杂的Stream结构。
• 添加try/catch块捕获上传过程中的实际错误（比如网络问题、权限意外变更等），方便定位问题。

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