如何用@aws-sdk/client-s3设置自定义请求头？含Cloudflare R2场景

能否设置该请求头？ #

可以。@aws-sdk/client-s3支持在请求中注入自定义HTTP头，完全可以添加Cloudflare R2的这个扩展请求头。

具体操作（NestJS环境） #

方式1：单个PutObject请求中直接添加 #

初始化S3客户端后，在构造PutObjectCommand时，直接通过headers字段传入目标请求头：

import { S3Client, PutObjectCommand } from '@aws-sdk/client-s3';
import { Injectable } from '@nestjs/common';

@Injectable()
export class R2StorageService {
  private s3Client: S3Client;

  constructor() {
    this.s3Client = new S3Client({
      region: 'auto',
      endpoint: 'https://<你的R2账户ID>.r2.cloudflarestorage.com',
      credentials: {
        accessKeyId: '<你的访问密钥ID>',
        secretAccessKey: '<你的秘密访问密钥>',
      },
    });
  }

  async uploadToR2(bucket: string, key: string, fileBuffer: Buffer) {
    const uploadCommand = new PutObjectCommand({
      Bucket: bucket,
      Key: key,
      Body: fileBuffer,
      // 添加Cloudflare R2扩展请求头
      headers: {
        'cf-create-bucket-if-missing': 'true',
      },
    });

    try {
      return await this.s3Client.send(uploadCommand);
    } catch (err) {
      throw err;
    }
  }
}

方式2：NestJS全局拦截器统一添加 #

如果希望所有S3出站PutObject请求自动带上该头，可以创建全局拦截器：

import { Injectable, NestInterceptor, ExecutionContext, CallHandler } from '@nestjs/common';
import { Observable } from 'rxjs';
import { tap } from 'rxjs/operators';
import { Command } from '@aws-sdk/smithy-client';

@Injectable()
export class R2AutoCreateBucketInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    return next.handle().pipe(
      tap((command: Command) => {
        // 仅对PutObject命令添加请求头
        if (command.constructor.name === 'PutObjectCommand') {
          command.input.headers = {
            ...command.input.headers,
            'cf-create-bucket-if-missing': 'true',
          };
        }
      }),
    );
  }
}

在模块中注册拦截器：

import { Module } from '@nestjs/common';
import { APP_INTERCEPTOR } from '@nestjs/core';
import { R2AutoCreateBucketInterceptor } from './r2.interceptor';
import { R2StorageService } from './r2.service';

@Module({
  providers: [
    R2StorageService,
    {
      provide: APP_INTERCEPTOR,
      useClass: R2AutoCreateBucketInterceptor,
    },
  ],
})
export class R2Module {}

替代方案（若SDK版本限制无法添加头） #

1. 预检查并创建桶：上传前先调用HeadBucket检查桶是否存在，不存在则调用CreateBucket创建，再执行上传。这种方式兼容性最强，但会多一次网络请求。
2. 手动构造签名请求：用axios或fetch直接调用R2 API，结合@aws-sdk/signature-v4包生成请求签名，手动添加目标请求头。这种方式完全可控，但需要自行处理签名逻辑。

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