Swift实现AWS S3多图高效批量上传及完成通知方案咨询

嗨，针对你遇到的多图上传耗时久、需要全量完成通知的问题，我给你整理了一个基于并行上传+DispatchGroup的解决方案，既能提升上传速度，又能精准跟踪所有任务的完成状态：

核心思路 #

原来循环串行调用单图上传的方式效率低，我们可以做两个关键优化：

• 并行执行上传任务：利用AWS TransferManager的线程池同时处理多个上传请求，充分利用系统资源
• 用DispatchGroup跟踪全量状态：通过enter()/leave()标记单个任务的开始和结束，所有任务完成后统一触发回调，完美解决同步数据的需求
• 额外优化：复用AWSS3TransferManager实例，避免重复初始化的开销

完整实现代码 #

定义一个专门的多图上传函数，支持批量传入图片路径、对应S3存储键，以及全量完成后的回调：

import AWSS3

func uploadMultipleImages(toS3Bucket bucketName: String, 
                          imagePaths: [String], 
                          s3Keys: [String], 
                          imageExtension: String = "jpeg",
                          completion: @escaping ([String?]) -> Void) {
    // 先校验输入参数的匹配性
    guard imagePaths.count == s3Keys.count else {
        print("Error: 图片路径数量和S3键数量不匹配")
        completion([])
        return
    }
    
    // 复用全局TransferManager实例
    let transferManager = AWSS3TransferManager.default()
    let uploadGroup = DispatchGroup()
    // 用数组存储每个图片的上传结果，索引和输入顺序对应
    var uploadedURLs: [String?] = Array(repeating: nil, count: imagePaths.count)
    
    for (index, path) in imagePaths.enumerated() {
        // 标记当前任务加入组
        uploadGroup.enter()
        
        let uploadRequest = AWSS3TransferManagerUploadRequest()
        uploadRequest?.acl = .publicRead
        uploadRequest?.body = URL(fileURLWithPath: path)
        uploadRequest?.key = s3Keys[index]
        uploadRequest?.bucket = bucketName
        uploadRequest?.contentType = "image/\(imageExtension)"
        
        // 并行执行上传任务
        transferManager.upload(uploadRequest!).continueWith { task in
            // 不管成功失败，都标记当前任务完成
            defer {
                uploadGroup.leave()
            }
            
            if let error = task.error {
                print("上传失败 ❌ 键名: \(s3Keys[index]) 错误: \(error)")
                uploadedURLs[index] = nil
            } else if task.result != nil {
                let s3URL = "http://s3.amazonaws.com/\(bucketName)/\(s3Keys[index])"
                print("上传成功 ✅ 地址:\n\(s3URL)")
                uploadedURLs[index] = s3URL
            } else {
                print("上传异常 ❌ 键名: \(s3Keys[index]) 无返回结果")
                uploadedURLs[index] = nil
            }
            return nil
        }
    }
    
    // 所有上传任务完成后，回到主线程触发回调
    uploadGroup.notify(queue: .main) {
        completion(uploadedURLs)
        print("所有上传任务已完成！")
        // 这里可以直接加入同步数据的逻辑，比如把成功的URL同步到你的后端
    }
}

使用示例 #

调用这个函数时，只需要传入批量的图片路径和对应的S3存储键，就能在回调里拿到所有上传结果：

// 示例：要上传的图片路径数组
let imagePaths = [
    "/Documents/photo1.jpeg",
    "/Documents/photo2.jpeg",
    "/Documents/photo3.jpeg"
]
// 对应的S3存储键（建议按业务规则命名，比如用户ID+文件名）
let s3Keys = [
    "user_456/avatar1.jpeg",
    "user_456/avatar2.jpeg",
    "user_456/avatar3.jpeg"
]

// 调用多图上传函数
uploadMultipleImages(toS3Bucket: S3BucketName, 
                     imagePaths: imagePaths, 
                     s3Keys: s3Keys) { uploadedURLs in
    // 处理上传结果：筛选出成功的URL
    let successfulURLs = uploadedURLs.compactMap { $0 }
    print("成功上传 \(successfulURLs.count) 张图片")
    
    // 在这里执行同步数据的逻辑，比如把successfulURLs发送到你的业务服务器
}

额外说明 #

如果需要跟踪单张图片的上传进度，可以在uploadRequest里设置uploadProgress闭包；如果需要总上传进度，可以结合全局计数器和DispatchQueue来统计，但如果只需要全量完成通知，上面的方案已经足够简洁高效。

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