Step Functions を使用して Amazon SQSキューにメッセージを送信する - AWS Step Functions

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Step Functions を使用して Amazon SQSキューにメッセージを送信する

Step Functions を使用して Amazon SQSキューにメッセージを送信する方法について説明します。このページには、サポートされている Amazon SQSAPIアクションが一覧表示され、キューにメッセージを送信するTask状態の例が表示されます。

との統合について学ぶには AWS Step Functions の サービスについては、 サービスとの統合「」および「」を参照してくださいStep Functions APIのサービスへのパラメータの受け渡し

最適化された Amazon SQS統合の主な機能

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

以下には、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 デベロッパーガイド「メッセージの受信と削除」を参照してください。

サポートされている Amazon SQS APIs

のパラメータ Step Functions は で表されます。 PascalCase

API アクション camelCaseなどのネイティブサービスAPIが にある場合でもstartSyncExecution、 などのパラメータを で指定します PascalCaseStateMachineArn

注記

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

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": "*" } ] }