Step Functions で Amazon SQS を呼び出す

Step Functions AWS は特定のサービスを Amazon ステートメント言語 (ASL) から直接制御できます。AWS Step Functions との協働および統合の詳細については、以下を参照してください。

• 他のサービスでの使用

• サービス API にパラメータを渡す

最適化された Amazon SQS 統合と Amazon SQS AWS SDK インタグレーションとの違い

レスポンスのリクエスト または タスクトークンのコールバックまで待機する 統合パターンの最適化はありません。

サポートされているAmazon SQS API:

注記

Step Functions のタスクには入力データまたは結果データの最大サイズにはクォータがあります。これにより、別のサービスとの間でデータを送受信するときに、UTF-8 でエンコードされた文字列として 256 KB のデータに制限されます。ステートマシンの実行に関連するクォータ を参照してください。

• SendMessage

  サポートされているパラメータ:

  • DelaySeconds

  • MessageAttribute

  • MessageBody

  • MessageDeduplicationId

  • MessageGroupId

  • QueueUrl

• Response syntax

以下には、Amazon Simple Queue Service (Amazon SQS) メッセージを送信する 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 Simple Queue Service デベロッパーガイドのメッセージの受信および削除を参照してください。

他の AWS サービスで Step Functions を使用して IAM を設定する方法については、「統合サービスの IAM ポリシー」を参照してください。