Node.js Lambda后端读取S3存储MP3文件计算音频时长的异常问题

• S3直链计算返回时长为0
  私有S3桶的直链如果没有携带有效签名，拉取到的内容是AWS返回的权限拒绝XML报文，完全不是合法的MP3二进制流。mp3Duration读到无效内容时不会抛错，只会静默返回0，这不是解析库适配的问题，是输入源本身就不对。
• /tmp目录下提示文件不存在
  代码完全没有适配JS的异步执行逻辑顺序：
  1. s3.getObject是带回调的异步接口，调用后不会等文件拉取完成就直接往下执行
  2. fs.writeFile也是异步写入接口，调用后不会等磁盘写入完成就直接往下执行
  3. mp3Duration的调用是和s3.getObject平级的同步逻辑，根本不会等前面两个异步流程跑完就启动读文件操作
     这时候/tmp下的目标文件还没被创建，读的时候自然报不存在。再加上原代码的错误拦截逻辑有漏洞：S3拉取失败、文件写入失败时只是打印日志，没有中断后续流程，遇到这类错误也会触发文件不存在的报错。

核心原则是确保每一步操作完成、没有报错的情况下，再执行下一步。把异步链路改成线性等待的写法，就能彻底解决这两个问题，修正后的可运行代码如下：

const AWS = require('aws-sdk');
const fs = require('fs');
const mp3Duration = require('mp3-duration');
const s3 = new AWS.S3();

async function getAudioDuration(bucketName, audioKey) {
  // 1. 拉取S3音频对象，等待拉取完成再往下走
  const s3Res = await s3.getObject({
    Bucket: bucketName,
    Key: audioKey
  }).promise();

  // 兼容不同SDK版本的返回体类型，统一转成可写入的Buffer
  const audioBuffer = Buffer.isBuffer(s3Res.Body) 
    ? s3Res.Body 
    : Buffer.from(await s3Res.Body.transformToByteArray());

  // 2. 等待文件写入/tmp完成
  const tmpFilePath = `/tmp/${audioKey.split('/').pop()}`;
  await fs.promises.writeFile(tmpFilePath, audioBuffer);

  // 3. 确认文件写入完成后再解析时长
  return new Promise((resolve, reject) => {
    mp3Duration(tmpFilePath, (err, duration) => {
      if (err) return reject(err);
      resolve(duration);
    })
  })
}

// Lambda入口调用
exports.handler = async (event) => {
  const bucketName = '你的存储桶名称';
  const audioKey = 'audio/filename.mp3';
  try {
    const duration = await getAudioDuration(bucketName, audioKey);
    console.log(`音频时长为${duration}秒`);
    return { duration };
  } catch (err) {
    console.error('时长计算失败', err);
    throw err;
  }
}

• 不要用多层回调嵌套写异步流程，优先用async/await把流程改成线性顺序，从根源上避免执行顺序错乱的问题
• Lambda的/tmp目录是实例级隔离存储，容量和函数配置的临时存储参数绑定，处理大文件前确认文件大小不超上限，避免触发写入失败
• 拉取S3对象时要做返回体类型兼容，不同版本的AWS SDK返回的Body类型不一致，不统一转成Buffer直接写文件会出现内容损坏、解析失败的问题
• mp3Duration仅支持MP3格式的时长解析，如果业务涉及WAV、M4A等其他格式的音频，要替换对应格式的解析逻辑，不要依赖单一解析库覆盖所有场景

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