能否在NestJS中通过文件流缓冲区上传至GCS？

NodeJS环境下完全支持通过文件流直接上传至GCS，@google-cloud/storage@6.9.1也提供了对应的功能，你没找到相关API大概率是对SDK的用法不够熟悉。

核心思路：跳过Multer的存储环节，直接流转上传 #

不用依赖Multer的内存存储或本地临时文件模式，直接从NestJS的请求中提取文件流，再通过GCS SDK的写入流完成上传——这样既不会产生额外的服务器存储成本，也不会因大文件一次性加载导致内存溢出。

具体实现（NestJS + @google-cloud/storage@6.9.1） #

1. 初始化GCS客户端

import { Storage } from '@google-cloud/storage';

// 初始化存储客户端（使用服务账号密钥，或依赖环境变量认证）
const storage = new Storage({
  keyFilename: './service-account-key.json',
});
// 指定目标存储桶
const targetBucket = storage.bucket('your-bucket-name');

2. 控制器中直接处理文件流

不需要使用@UploadedFile这类Multer装饰器，直接通过Express的Request对象解析FormData并处理流：

import { Controller, Post, Req } from '@nestjs/common';
import { Request } from 'express';
import * as Busboy from 'busboy';

@Controller('uploads')
export class UploadController {
  @Post()
  async uploadToGcs(@Req() req: Request) {
    return new Promise((resolve, reject) => {
      const busboy = Busboy({ headers: req.headers });
      
      busboy.on('file', (fieldname, fileStream, filename) => {
        // 创建GCS文件的写入流
        const gcsFile = targetBucket.file(filename.filename);
        const gcsWriteStream = gcsFile.createWriteStream({
          resumable: true, // 开启可恢复分块上传，适合大文件
          contentType: fileStream.mimeType,
          gzip: true, // 可选，开启Gzip压缩
        });

        // 将请求文件流直接pipe到GCS写入流
        fileStream.pipe(gcsWriteStream);

        // 监听上传状态
        gcsWriteStream.on('finish', () => {
          resolve({
            success: true,
            fileUrl: `https://storage.googleapis.com/${targetBucket.name}/${filename.filename}`,
          });
        });

        gcsWriteStream.on('error', (err) => {
          reject(new Error(`上传失败：${err.message}`));
        });
      });

      req.pipe(busboy);
    });
  }
}

注：Busboy是Multer底层依赖的FormData解析库，需要单独安装：npm install busboy

关于@google-cloud/storage的写入流API #

你要找的流上传功能对应SDK中的createWriteStream方法，该方法由bucket.file()返回的File实例提供。当设置resumable: true时，SDK会自动将大文件分块（默认每块8MB）上传，全程不会将文件完整加载到内存，完美解决你担心的内存溢出问题。

额外优化建议 #

• 可以封装一个NestJS自定义拦截器，将流上传逻辑抽离，让控制器代码更简洁；
• 针对大文件，可以通过chunkSize参数自定义分块大小；
• 上传前可以添加文件类型、大小校验，避免无效请求。

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