如何通过ASP.NET Core 2应用将客户端文件直接流式上传至S3

我完全懂你的痛点——先存本地再转S3不仅浪费磁盘资源，还平白增加IO开销，偏偏又不能用预签名URL方案。下面是针对ASP.NET Core 2的具体实现思路，全程流式处理，完全跳过本地存储环节：

第一步：配置ASP.NET Core禁用表单数据缓存 #

默认情况下，ASP.NET Core会把多部分表单数据缓冲到本地磁盘或内存，这正是我们要规避的。在Startup.cs的ConfigureServices里修改请求表单配置：

services.Configure<FormOptions>(options =>
{
    // 禁用整个请求体的缓冲，强制流式处理
    options.BufferBody = false;
    // 把内存缓冲阈值设到最大，避免小文件也被写入磁盘
    options.MemoryBufferThreshold = int.MaxValue;
    // 根据业务需求调整允许的最大表单/文件大小
    options.ValueLengthLimit = int.MaxValue;
    options.MultipartBodyLengthLimit = 1073741824; // 1GB，按需修改
});

第二步：手动解析多部分表单并流式上传到S3 #

别用默认的IFormFile绑定（它还是会悄悄把文件缓存到本地），直接用MultipartReader读取原始请求流，拿到文件的Stream后直接传给S3客户端：

控制器Action示例 #

using Amazon.S3;
using Amazon.S3.Model;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Http.Headers;

[HttpPost]
public async Task<IActionResult> Upload()
{
    // 先校验请求格式
    if (!Request.HasFormContentType)
    {
        return BadRequest("请求格式错误，请使用多部分表单提交");
    }

    // 获取表单边界符
    var boundary = MultipartRequestHelper.GetBoundary(
        MediaTypeHeaderValue.Parse(Request.ContentType),
        1024); // 边界符最大长度，按需调整

    var reader = new MultipartReader(boundary, Request.Body);
    MultipartSection section;

    // 建议把S3客户端注册为依赖注入服务，这里为了示例直接创建
    var s3Client = new AmazonS3Client(RegionEndpoint.USEast1);

    while ((section = await reader.ReadNextSectionAsync()) != null)
    {
        var contentDisposition = ContentDispositionHeaderValue.Parse(section.ContentDisposition);
        
        // 判断当前部分是文件还是普通表单字段
        if (!string.IsNullOrEmpty(contentDisposition.FileName.Value))
        {
            // 直接用请求流上传到S3，全程不碰本地磁盘
            var putRequest = new PutObjectRequest
            {
                BucketName = "your-target-bucket",
                Key = $"uploads/{contentDisposition.FileName.Value}", // S3存储路径
                InputStream = section.Body, // 传入原始请求流
                ContentType = section.ContentType.ToString()
            };

            await s3Client.PutObjectAsync(putRequest);
        }
        else
        {
            // 处理表单中的非文件字段（比如用户ID、备注等）
            var fieldName = contentDisposition.Name.Value;
            var fieldValue = await section.ReadAsStringAsync();
            // 这里可以添加你的业务逻辑，比如记录字段值
        }
    }

    return Ok("文件上传完成");
}

关键注意事项 #

• S3客户端优化：一定要把AmazonS3Client注册为单例或Scoped服务，不要在Action里重复创建，避免资源浪费。
• 错误处理：记得添加异常捕获逻辑，比如S3上传失败、请求中断等场景的兜底处理。
• 大文件场景：如果要上传超大文件，可以改用TransferUtility.UploadAsync的流式重载，它会自动分块上传S3，避免内存溢出。
• 命名空间引用：确保引用了Microsoft.AspNetCore.Http、Amazon.S3等必要的命名空间。

这个方案全程流式传输，完全跳过本地存储，完美解决你的资源节省需求。

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