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

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

若要瞭解如何整合 AWS 服務在 Step Functions 中，請參閱整合 服務和。將參數傳遞給 Step Functions 數API中的服務

優化 Amazon SQS 集成的主要功能

請求回應或使用任務令牌等待回調整合模式沒有最佳化。

以下內容包括傳送 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 簡單佇列服務開發人員指南中的接收和刪除訊息。

支持 Amazon SQS APIs

• SendMessage

  支援的參數：

  • DelaySeconds

  • MessageAttribute

  • MessageBody

  • MessageDeduplicationId

  • MessageGroupId

  • QueueUrl

• Response syntax

參數 Step Functions 表示於 PascalCase

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

注意

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

IAM致電 Amazon 政策 SQS

下面的示例模板顯示如何 AWS Step Functions 根據狀態機器定義中的資源產生IAM策略。如需詳細資訊，請參閱 Step Functions 式如何為整合式服務產生IAM原則 和 探索 Step Functions 中的服務整合模式。

靜態資源

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "sqs:SendMessage"
            ],
            "Resource": [
                "arn:aws:sqs:[[region]]:[[accountId]]:[[queueName]]"
            ]
        }
    ]
}
        

動態資源

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "sqs:SendMessage"
            ],
            "Resource": "*"
        }
    ]
}