翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
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": "*"
}
]
}