0

我想在应用重启后重试之前失败的 S3 上传任务。在应用程序初始化时，我打电话

    // register a transfer utility object asynchronously
    AWSS3TransferUtility.register(
        with: configuration!,
        transferUtilityConfiguration: tuConf,
        forKey: "..." // redacted
    ) { (error) in
         if let error = error {
             // handle registration error.
            Logging.logError("Error in registration: \(error)")
         } else {
            Logging.logDebug("AWS S3 TransferUtility registration success, now check for pending tasks")
            DispatchQueue.global().asyncAfter(deadline: .now() + 2.0) {
                finishPendingTasks()
            }
        }
    }

这是完成待处理任务的功能

  static func finishPendingTasks() {
    let transferUtility = AWSS3TransferUtility.default()
    let uploadTasks = transferUtility.getUploadTasks().result

    Logging.logDebug("Finish pending AWS upload tasks")
    var progressBlock: AWSS3TransferUtilityProgressBlock?
    progressBlock = {(task, progress) in
        DispatchQueue.main.async(execute: {
            // Do something e.g. Update a progress bar.
            Logging.logDebug("upload in process \(progress)")
        })
    }

    var completionHandler: AWSS3TransferUtilityUploadCompletionHandlerBlock?
    completionHandler = { (task, error) -> Void in
        DispatchQueue.main.async(execute: {
            // Do something e.g. Alert a user for transfer completion.
            // On failed uploads, `error` contains the error object.
            Logging.logDebug("upload completed1 \(task.bucket)")
            Logging.logDebug("upload completed2 \(String(describing: task.response))")
            Logging.logDebug("upload completed3 \(task.key)")
            Logging.logDebug("upload error \(String(describing: error))")
        })
    }

    let taskCount = uploadTasks?.count ?? 0
    Logging.logDebug("Number of upload tasks: \(taskCount)")
    for task in uploadTasks! {
        if let awsTask = task as? AWSS3TransferUtilityUploadTask {
            Logging.logDebug("Resuming uploading task key \(awsTask.key), transfer ID: \(awsTask.transferID), status: \(awsTask.status.rawValue)")
            awsTask.setCompletionHandler(completionHandler!)
            awsTask.setProgressBlock(progressBlock!)
            awsTask.resume() // <------- HAS NO EFFECT!
        }
    }
}

状态 rawValue 为 0

不确定 resume() 是否是触发重试的原因。是否有记录在某处的程序？

没有看到完成处理程序/进度块启动。

从这个角度来看，AWS 似乎并没有真正跟踪与任务相关的数据，并且看起来必须手动维护和上传数据。

知道如何处理重试吗？

4

1 回答 1

0

默认情况下，重试限制似乎为0。可以通过设置更改

AWSS3TransferUtilityConfiguration().retryLimit = ...

resume() 在这种情况下不适用。

于 2020-10-20T04:23:50.080 回答