1
你好，並提前感謝您的時間。在Swift中使用AWSTask對象的正確方法是什麼？
在我的代碼中，我正在向AWSSQS發出各種請求，這些請求都返回AWSTask。我發現使用這些AWSTask對象非常困難，同時也試圖將所有特定於AWS的邏輯保存在一個類中，以便在需要時可以輕鬆切換到不同的雲服務。
理想情況下，我想要做的是以串行方式異步執行一系列AWS任務。通常我只是將任務添加到自定義的串行調度隊列中，但由於AWSTask對象本身就是異步任務，所以我不能這麼做。
下面是一個簡單的例子，說明我遇到的問題。它沒有任何真正的世界目的，但它很好地解釋了這個問題。下面，我有創建SQS隊列，發送消息到SQS隊列，接收來自SQS隊列的消息，並刪除SQS隊列的代碼。假設我想以串行，異步的方式來完成這四件事情。換句話說，我想在嘗試下一個任務之前確保先前的任務成功。
的ViewController
DispatchQueue.global(qos: DispatchQoS.QoSClass.userInitiated).async {
awsClass.runTest()
DispatchQueue.main.async {
print("Test Finished")
}
}
AwsClass
public func createQueue(){
guard let createQueueRequest = AWSSQSCreateQueueRequest() else{fatalError()}
createQueueRequest.queueName = "TestQueue"
sqs.createQueue(createQueueRequest).continueWith(block: {(task) -> AnyObject? in
if task.error != nil {
print(task.error!)
}
else if task.result != nil {
self.queueUrl = task.result!.queueUrl!
print("created queue at: \(self.queueUrl!)")
}
return nil
})
}
public func deleteQueue(){
if queueUrl != nil {
guard let deleteQueueRequest = AWSSQSDeleteQueueRequest() else{fatalError()}
deleteQueueRequest.queueUrl = queueUrl
sqs.deleteQueue(deleteQueueRequest).continueWith(block: {(task) -> AnyObject? in
if task.error != nil {
print(task.error!)
}
else if task.result != nil {
print("queue sucessfully deleted from \(self.queueUrl!)")
self.queueUrl = nil
}
return nil
})
}
else{
print("Queue has already been deleted")
}
}
public func sendMessage(messageData: String, toConnectId: String) {
guard let sendMessageRequest = AWSSQSSendMessageRequest() else{fatalError()}
sendMessageRequest.queueUrl = toConnectId
sendMessageRequest.delaySeconds = 0
sendMessageRequest.messageBody = messageData
sqs.sendMessage(sendMessageRequest).continueWith(block: {(task) -> AnyObject? in
if task.error != nil {
print(task.error!)
}
else if task.result != nil {
print("successfully sent message to \(toConnectId)")
}
return nil
})
}
public func receiveMessage(){
guard let receiveMessageRequest = AWSSQSReceiveMessageRequest() else{fatalError()}
receiveMessageRequest.queueUrl = self.queueUrl
receiveMessageRequest.maxNumberOfMessages = 1
sqs.receiveMessage(receiveMessageRequest).continueWith(block: {(task) -> AnyObject? in
if task.error != nil {
print(task.error!)
}
else if task.result != nil {
let message = (task.result?.messages?.first)!
print("successfully received message with body: \(message.body ?? "failed")")
}
return nil
})
}
public func runTest(){
let mySerialQueue = DispatchQueue(label: "mySerialQueue")
mySerialQueue.sync {
self.createQueue()
}
mySerialQueue.sync {
self.sendMessage(messageData: "test", toConnectId: "https://someUrl")
}
mySerialQueue.sync {
self.receiveMessage()
}
mySerialQueue.sync {
self.deleteQueue()
}
}
由於AWSTasks是異步完成的功能，代碼很快使所有四個呼叫，然後通過完成函數被調用時這些任務完成。相反，我希望第一個任務的完成功能在下一個任務開始之前完成。