Node.js应用上传文件至S3：不存在则创建Bucket的实现方案

当然可以实现这个需求！我们可以利用AWS SDK提供的方法先校验Bucket是否存在，不存在就创建，之后再执行上传。下面是调整后的代码，用async/await处理异步流程，代码更清晰易读：

async function uploadit() {
  'use strict';
  console.log('Preparing to upload the verse.');
  
  const AWS = require('aws-sdk');
  const s3 = new AWS.S3({ apiVersion: '2006-03-01' });
  const bucketName = 'DynamicBucketName'; // 你的动态Bucket名称
  const uploadParams = {
    Bucket: bucketName,
    Key: 'your-file-key-here', // 替换成你的文件键名
    Body: 'your-file-content-or-stream', // 替换成你的文件内容/流
    // 可按需添加其他参数，比如ContentType、ACL等
  };

  try {
    // 第一步：检查Bucket是否存在
    await s3.headBucket({ Bucket: bucketName }).promise();
    console.log(`Bucket ${bucketName} 已存在，直接准备上传`);
  } catch (headErr) {
    // headBucket失败大概率是Bucket不存在（也可能是权限问题）
    if (headErr.code === 'NotFound') {
      console.log(`Bucket ${bucketName} 不存在，开始创建...`);
      // 第二步：创建Bucket
      await s3.createBucket({ Bucket: bucketName }).promise();
      console.log(`Bucket ${bucketName} 创建成功`);
      // 可选：如果需要设置Bucket权限/配置，可在此添加
      // 例如设置公开读取权限：await s3.putBucketAcl({ Bucket: bucketName, ACL: 'public-read' }).promise();
    } else {
      // 其他异常（如权限不足）直接抛出
      throw new Error(`检查Bucket时出错: ${headErr.message}`);
    }
  }

  try {
    // 第三步：执行上传
    const uploadResult = await s3.upload(uploadParams).promise();
    console.log(`文件上传成功！地址：${uploadResult.Location}`);
    return uploadResult;
  } catch (uploadErr) {
    throw new Error(`文件上传失败: ${uploadErr.message}`);
  }
}

// 调用上传函数（记得处理可能的错误）
uploadit().catch(err => console.error('上传流程出错:', err));

几个关键点说明： #

• 为什么用headBucket？ 相比listBuckets方法，headBucket只需要对目标Bucket的权限，不需要列出所有Bucket的权限，更高效也更安全。如果Bucket不存在，它会抛出NotFound错误，我们就可以捕获这个错误触发创建逻辑。
• 异步流程处理：用async/await替代回调函数，避免了回调地狱，代码逻辑更线性，更容易维护。
• 错误处理：分阶段捕获错误，区分“Bucket不存在”和其他异常（比如权限问题），让错误排查更清晰。
• 动态Bucket适配：你只需要把bucketName替换成你的动态名称变量即可，完全适配你的需求。

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