Step Functions를 사용하여 Amazon SQS 대기열로 메시지 보내기 - AWS Step Functions
지원됨 APIsIAM정책

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Step Functions를 사용하여 Amazon SQS 대기열로 메시지 보내기

Step Functions를 사용하여 Amazon SQS 대기열로 메시지를 보내는 방법을 알아보십시오. 이 페이지는 지원되는 Amazon SQS API 작업을 나열하고 메시지를 대기열로 보내는 예제 Task 상태를 제공합니다.

와의 통합에 대해 알아보려면 AWS Step Functions의 서비스에 대해서는 및 을 참조하십시오 서비스 통합. Step API Functions에서 서비스에 파라미터 전달하기

최적화된 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에서 메시지를 수신하는 방법에 대해 자세히 알아보려면 Amazon SQS Simple Queue Service 개발자 안내서의 메시지 수신 및 삭제를 참조하십시오.

아마존 지원 SQS APIs

매개 변수 입력 Step Functions 다음과 같이 표현됩니다. PascalCase

예를 camelCase startSyncExecution 들어 API 액션에 네이티브 API 서비스가 포함되어 있더라도 다음과 같은 매개 변수를 지정합니다StateMachineArn. PascalCase

참고

Step Functions에는 작업의 최대 입력 또는 결과 데이터 크기에 대한 할당량이 있습니다. 이렇게 하면 다른 서비스에 데이터를 보내거나 다른 서비스로부터 데이터를 받을 때 256KB의 데이터를 UTF -8로 인코딩된 문자열로 제한합니다. 상태 시스템 실행과 관련된 할당량을 참조하세요.

IAM아마존 통화 정책 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": "*"
        }
    ]
}