如何基于Azure Function实现多文件上传至Blob存储的最优方案？

针对你提供的单文件上传代码，以下是优化后的多文件上传实现方案，兼顾效率、可靠性和可维护性：

完整实现代码 #

public static class MultiFileUpload
{
    [FunctionName("MultiFileUpload")]
    public static async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, 
        ILogger log)
    {
        // 从环境变量读取存储配置
        string storageConnection = Environment.GetEnvironmentVariable("AzureWebJobsStorage");
        string containerName = Environment.GetEnvironmentVariable("ContainerName");

        if (string.IsNullOrEmpty(storageConnection) || string.IsNullOrEmpty(containerName))
        {
            log.LogError("缺少存储连接字符串或容器名称配置");
            return new BadRequestObjectResult("配置缺失，请检查环境变量");
        }

        // 检查是否有上传文件
        if (req.Form.Files.Count == 0)
        {
            return new BadRequestObjectResult("未检测到上传文件");
        }

        var containerClient = new BlobContainerClient(storageConnection, containerName);
        // 确保容器存在（不存在则自动创建）
        await containerClient.CreateIfNotExistsAsync();

        var uploadTasks = new List<Task>();
        var uploadResults = new List<(string FileName, bool Success, string Message)>();

        foreach (var file in req.Form.Files)
        {
            if (file.Length == 0)
            {
                uploadResults.Add((file.FileName, false, "文件为空"));
                continue;
            }

            // 生成唯一文件名，避免覆盖已有文件
            string uniqueFileName = $"{Path.GetFileNameWithoutExtension(file.FileName)}_{DateTime.UtcNow:yyyyMMddHHmmss}{Path.GetExtension(file.FileName)}";
            var blobClient = containerClient.GetBlobClient(uniqueFileName);

            // 异步上传并记录结果
            var uploadTask = file.OpenReadStream().UploadToAsync(blobClient)
                .ContinueWith(task =>
                {
                    if (task.IsCompletedSuccessfully)
                    {
                        uploadResults.Add((file.FileName, true, "上传成功"));
                        log.LogInformation($"文件 {file.FileName} 已成功上传为 {uniqueFileName}");
                    }
                    else
                    {
                        string errorMsg = task.Exception?.InnerException?.Message ?? "未知错误";
                        uploadResults.Add((file.FileName, false, $"上传失败：{errorMsg}"));
                        log.LogError(task.Exception, $"文件 {file.FileName} 上传失败");
                    }
                });

            uploadTasks.Add(uploadTask);
        }

        // 等待所有上传任务完成
        await Task.WhenAll(uploadTasks);

        return new OkObjectResult(new
        {
            TotalFiles = req.Form.Files.Count,
            UploadResults = uploadResults
        });
    }
}

关键改进说明 #

• 多文件遍历处理：遍历req.Form.Files集合，处理所有上传的文件，而非单个指定文件
• 并发异步上传：使用Task.WhenAll并行处理多个文件上传，大幅提升上传效率
• 可靠性保障：
  • 提前检查配置和上传文件是否存在，返回明确的错误信息
  • 自动创建Blob容器（若不存在）
  • 过滤空文件，避免无效上传操作
• 文件名冲突解决：通过添加UTC时间戳后缀生成唯一文件名，防止覆盖已有Blob
• 结果反馈：返回每个文件的上传状态，便于调用方排查问题

生产环境注意事项 #

• 权限控制：将AuthorizationLevel.Anonymous改为AuthorizationLevel.Function或AuthorizationLevel.Admin，避免匿名访问带来的安全风险
• 大文件支持：Azure Function默认请求大小限制为100MB，若需上传更大文件，需在host.json中配置：

  {
      "extensions": {
          "http": {
              "maxHttpRequestSize": 1048576000 // 1GB，单位为字节
          }
      }
  }
  

• 依赖更新：确保引用最新版的Azure.Storage.Blobs NuGet包，获得更好的性能和稳定性
• 日志监控：利用Azure Monitor监控函数运行日志，及时排查上传失败的问题

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