【发布时间】:2021-06-16 04:50:47
【问题描述】:
我在使用 Swift 中的预签名 url 在 S3 存储桶中以块的形式上传多部分数据时收到错误消息。
我的代码是:-
func AWSS3UploadMultipartData(data: Data, strVideoName : String, strContentType: String , _ completion: @escaping s3CompletionHandler)
{
let multipartRequest = AWSS3CreateMultipartUploadRequest()
multipartRequest?.key = strVideoName
multipartRequest?.bucket = S3BucketName
multipartRequest?.contentType = strContentType
let awsService = AWSS3.default()
awsService.createMultipartUpload(multipartRequest!) { (multipartUploadOutput, error) in
self.multipartUploadId = multipartUploadOutput?.uploadId
self.completedPartsInfo = AWSS3CompletedMultipartUpload()
self.uploadAllParts()
}
}
func uploadAllParts ()
{
repeat {
// get the length of the chunk
let thisChunkSize = xxxxx;
// get the chunk data
let chunk = xxxxxx
//saving the file to Documents Directory in chunkURL
self.uploadAWSPart(uploadDict: dict, fileURL: chunkURL!, mediaName : fileName,
awsPartNumber: offset)
offset += thisChunkSize;
} while (offset < length);
}
func uploadAWSPart(uploadDict : [String : Any], fileURL : URL, mediaName : String, awsPartNumber : Int)
{
let getPreSignedURLRequest = AWSS3GetPreSignedURLRequest()
getPreSignedURLRequest.bucket = S3BucketName
getPreSignedURLRequest.key = mediaName
getPreSignedURLRequest.httpMethod = AWSHTTPMethod.PUT;
getPreSignedURLRequest.expires = Date(timeIntervalSinceNow: 36 * 60 * 60);
getPreSignedURLRequest.contentType = contentType
getPreSignedURLRequest.setValue(self.multipartUploadId, forRequestParameter: "uploadId")
getPreSignedURLRequest.setValue(String(awsPartNumber), forRequestParameter: "partNumber")
let MD5 = self.md5File(url: fileURL)
getPreSignedURLRequest.contentMD5 = MD5
let presignedTask =
AWSS3PreSignedURLBuilder.default().getPreSignedURL(getPreSignedURLRequest)
presignedTask.continueWith(executor: AWSExecutor.mainThread(), block: { (task:AWSTask!) -> AnyObject! in
if let presignedURL = task.result
{
///This is the response of presignedURL:-
*******************************************************
https://bucketName.s3-ap-south-
1.amazonaws.com/c9e407127756360d54b85a469b728e0d_1534190164.75355.mp4?
X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-
Credential=AKIAIBZJLCO6SJCZZ7YQ%2F20180813%2Fap-south-
1%2Fs3%2Faws4_request&X-Amz-Date=20180813T195604Z&X-Amz-
Expires=129599&X-Amz-SignedHeaders=content-md5%3Bcontent-
type%3Bhost&uploadId=RSjis.pARzI3IPESBYvxWhcY5ta_ybURr7fnUK4fKBVTTS9cMjyVfG4nmJVAu
O.cQ.K7mSAPpLzLwW7CElIUyFaXnMmCTrr7A2p7r1KG79Q-&partNumber=0&X-Amz-
Signature=f2d555fd64f80e1ba86c8ed0b0eb63a1b184304fcbfde6a91198163df2a67900
*********************************************************
self.startUploadForPresignedURL (presignedURL as URL, chunkURL: fileURL, md5 :
MD5!, MediaName : mediaName, strContentType : contentType, awsPartNumber:
awsPartNumber)
}
return nil
})
}
func startUploadForPresignedURL (_ presignedURL:URL, chunkURL: URL, md5 : String, MediaName : String, strContentType : String, awsPartNumber: Int)
{
let request = NSMutableURLRequest(url: presignedURL)
request.cachePolicy = .reloadIgnoringLocalCacheData
request.timeoutInterval = Date(timeIntervalSinceNow: 36 * 60 * 60).timeIntervalSinceNow
request.httpMethod = "PUT"
request.setValue("public-read", forHTTPHeaderField: "x-amz-acl")
request.setValue(MediaName, forHTTPHeaderField: "filename")
request.setValue(strContentType, forHTTPHeaderField: "Content-Type")
request.setValue(self.md5File(url: chunkURL), forHTTPHeaderField: "Content-MD5")
let uploadTask = self.session?.uploadTask(with: request as URLRequest, fromFile: chunkURL)
uploadTask?.taskDescription = String(awsPartNumber)
uploadTask?.resume()
}
func urlSession(_ session: URLSession, task: URLSessionTask, didCompleteWithError error: Error?) {
print("\(#function)")
if (error != nil) {
print("didCompleteWithError error: \(String(describing: error?.localizedDescription))")
}
else {
print("didCompleteWithError success: \(String(describing: task.response))")
}
}
错误是:-
<NSHTTPURLResponse: 0x1c4432b60> { URL: https://bucketName.s3-ap-Region.amazonaws.com/xxxxx.mp4?X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Credential=AKIAIBZJLCO6SJCZZ7YQ%2F20180812%2Fap-south-1%2Fs3%2Faws4_request&X-Amz-Date=20180812T190423Z&X-Amz-Expires=129599&X-Amz-SignedHeaders=content-md5%3Bcontent-type%3Bhost&uploadId=rtRmP_xSnCVBURpnAnUFSbN5JLy9h11yDyDxtrTmMc9oAFMfIi95hX82bbupk497uIoHtC5tYXezK2fLcHb7fh_aR1win8eiAYCcKakmxvo-&partNumber=17825792&X-Amz-Signature=39d31e9f41371242099164702d329d8e81e6f4b16fabba0ed29507ceabc05130 } { Status Code: 403, Headers {
Connection = (
close
);
"Content-Type" = (
"application/xml"
);
Date = (
"Sun, 12 Aug 2018 19:04:30 GMT"
);
Server = (
AmazonS3
);
"Transfer-Encoding" = (
Identity
);
"x-amz-id-2" = (
"0bmVCpzxQZRVYUSeEKIMrxq0rMd9Ts5eYne7timdoH++ThvvNJo+Wjq9Jhckx/AP1fNiaPhVhqQ="
);
"x-amz-request-id" = (
C171A1AE06D092EF
);
} })
我尝试了不同的选项,但都没有奏效。我也尝试过使用 Alamofire 进行分段流上传,但同样的错误正在出现。我也将此问题发布到 github 中的 aws-sdk-ios,但他们直到现在也没有正确的答案。任何帮助将不胜感激。
【问题讨论】:
标签: ios swift amazon-web-services