使用sharp对Google Cloud Storage流式下载的图片resize报错如何解决

问题成因 #

核心问题出在流处理的逻辑错误上：

• downloadFileStream 中调用 pipe() 时没有传入目标流作为参数，该方法无参调用时返回值为 undefined，同时你给同步返回可读流的 createReadStream() 加了无意义的 await 包装，最终传递给 resize 方法的 imageObj 是无效的 undefined
• 代码中没有给出 resize 方法的实现，按照sharp的标准流式用法，如果没有正确将源流导入sharp转换流，也会导致返回值不是合法可读流，调用pipe时触发Cannot read property 'on' of undefined报错
• 额外冗余的async/await包装打破了Node.js流式处理的正常逻辑，流本身不是Promise类型，不需要用await等待返回

修复方案 #

直接按Node.js流的标准处理逻辑串联GCS下载流、sharp转换流和响应流即可，修复后完整代码如下：

const express = require('express')
const sharp = require('sharp')
const {Storage} = require('@google-cloud/storage');
const server = express()
const storage = new Storage();
const bucketName = '<some-bucket-name>'

server.get('/*', (req, res, next) => {
  try {
    // 原有参数提取逻辑保留
    const widthString = req.query.width
    const heightString = req.query.height
    const format = req.query.format || 'png'
    const fileName = req.path.substring(1);
    console.log("url: ", req.path)
    
    let width, height
    if (widthString) width = parseInt(widthString)
    if (heightString) height = parseInt(heightString)
    
    res.type(`image/${format}`)
    
    // 直接创建GCS可读流
    const gcsReadStream = storage.bucket(bucketName).file(fileName).createReadStream()
    // 创建sharp转换流，配置resize和输出格式规则
    const resizeTransform = sharp()
      .resize(width, height, {
        fit: 'contain', // 可按需调整适配模式：cover/fill/contain等
        withoutEnlargement: true // 避免小尺寸原图被强制放大失真
      })
      .toFormat(format)
    
    // 串联三个流完成下载、处理、返回全流程
    gcsReadStream
      .on('error', e => {
        console.error('GCS文件下载失败:', e)
        res.sendStatus(404)
      })
      .pipe(resizeTransform)
      .on('error', e => {
        console.error('图片处理失败:', e)
        res.sendStatus(500)
      })
      .pipe(res)
  } catch (e) {
    console.error('服务异常:', e)
    res.sendStatus(500)
  }
})

server.listen(3000, () => console.log('图片处理服务已启动，端口3000'))

修改说明 #

1. 移除了冗余的downloadFileStream封装，直接创建GCS可读流，避免无效返回值问题
2. 正确使用sharp的转换流能力，无需额外封装resize方法即可完成参数配置
3. 补充了各流节点的错误监听，可处理文件不存在、图片格式非法等异常场景，避免服务崩溃
4. 移除了不必要的async/await包装，符合Node.js流式处理的标准写法

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