使用 Step Functions 將消息發送到 Amazon SQS 隊列

了解如何使用 Step Functions 將訊息傳送到 Amazon SQS 佇列。此頁面列出支援的 Amazon SQS API 動作，並提供將訊息傳送至佇列的範例Task狀態。

Step Functions 可以直接從Amazon States Language（ASL）控制某些 AWS 服務。如需了解詳細資訊，請參閱 整合其他服務 和 將參數傳遞給 Step Functions 數API中的服務。

如何優化 Amazon SQS 集成與 Amazon SQS AWS SDK 集成不同

請求回應或等候傳回任務字符的回呼整合模式沒有最佳化。

支持 Amazon SQSAPIs：

注意

「Step Functions 數」中的工作有最大輸入或結果資料大小的配額。當您傳送至其他服務或從其他服務接收資料時，這會將您限制為 256 KB 的資料，以 UTF -8 編碼字串形式。請參閱 與狀態機器執行相關的配額。

• SendMessage

  支援的參數：

  • DelaySeconds

  • MessageAttribute

  • MessageBody

  • MessageDeduplicationId

  • MessageGroupId

  • QueueUrl

• Response syntax

中的參Step Functions數表示於 PascalCase

即使原生服務位API於中 camelCase (例如API動作)startSyncExecution，您也可以在中指定參數 PascalCase，例如：StateMachineArn。

以下內容包括傳送 Amazon 簡單佇列服務 (AmazonSQS) 訊息的Task狀態。

{
 "StartAt": "Send to SQS",
 "States": {
   "Send to SQS": {
     "Type": "Task",
     "Resource": "arn:aws:states:::sqs:sendMessage",
     "Parameters": {
       "QueueUrl": "https://sqs.us-east-1.amazonaws.com/123456789012/myQueue",
       "MessageBody.$": "$.input.message",
       "MessageAttributes": {
         "my_attribute_no_1": {
           "DataType": "String",
           "StringValue": "attribute1"
         },
         "my_attribute_no_2": {
           "DataType": "String",
           "StringValue": "attribute2"
         }
       }
     },
     "End": true
    }
  }
}

以下內容包括發佈到 Amazon SQS 佇列，然後等待任務權杖傳回的Task狀態。請參閱 等候傳回任務字符的回呼。

{  
   "StartAt":"Send message to SQS",
   "States":{  
      "Send message to SQS":{  
         "Type":"Task",
         "Resource":"arn:aws:states:::sqs:sendMessage.waitForTaskToken",
         "Parameters":{  
            "QueueUrl":"https://sqs.us-east-1.amazonaws.com/123456789012/myQueue",
            "MessageBody":{  
               "Input.$":"$",
               "TaskToken.$":"$$.Task.Token"
            }
         },
         "End":true
      }
   }
}

若要進一步了解如何在 Amazon 中接收訊息SQS，請參閱 Amazon 簡單佇列服務開發人員指南中的接收和刪除訊息。

如需Step Functions與其他 AWS 服務搭配使用時如何設定IAM權限的相關資訊，請參閱Step Functions 式如何為整合式服務產生IAM原則。