AWS SQS 작업

이 페이지는 작업우 자동화 작업 카탈로그에서 사용할 수 있는 AWS SQS 작업에 대한 포괄적인 참조 정보를 제공합니다. 이러한 작업을 통해 SQS 큐 작업을 관리할 수 있습니다.

전제 조건

블리자드 자동화에서 AWS 작업을 사용하기 전에 다음 사항이 있는지 확인하세요.

적절한 권한이 있는 AWS 계정.
AWS 자격 증명이 구성되었습니다(IAM 사용자 자격 증명, IAM 역할 ARN 또는 세션 자격 증명).
사용하려는 특정 AWS 서비스에 필요한 IAM 권한입니다.

IAM 사용자 및 IAM 역할을 생성하는 방법과 AWS 작업 자동화와의 통합을 위한 정적 및 세션 AWS 자격 증명을 설정하는 방법에 대한 자세한 내용은 AWS 자격 증명 설정하기를 참조하세요.

지정된 Amazon SQS 대기열로 메시지를 보냅니다.

입력 필드	선택성	유형	예시
awsRoleArn	선택 과목	문자열	`arn:aws:iam::123456789012:role/my-workflow-role`
awsAccessKeyId	선택 과목	문자열	`${{ :secrets:<awsAccessKeyId> }}`
awsSecretAccessKey	선택 과목	문자열	`${{ :secrets:<awsSecretAccessKey> }}`
awsSessionToken	선택 과목	문자열	`${{ :secrets:<awsSessionToken> }}`
지역	필수의	문자열	`"us-east-2"`
대기열 URL	필수의	문자열	" `https://sqs.us-east-2.amazonaws.com/123456789012/my-queue` "
메시지 본문	필수의	문자열	`"This is a test message"`
메시지 중복 제거 ID	선택 과목	문자열	`"abc123deduplicationId5678"`
메시지 그룹 ID	선택 과목	문자열	`"group1"`
메시지 속성	선택 과목	지도	`{ "my_attribute_name_1": { "DataType": "String", "StringValue":"my_attribute_value_1"}, "my_attribute_name_2": { "DataType": "String", "StringValue":"my_attribute_value_2"}}`
지연초	선택 과목	Int	`123`

출력 필드	유형	예시
response	물체	`{"statusCode":200, "payload":{"status":"success","data":{"MessageId":"e9b73a52-d018-4a73-9fcd-8efb682fba43","MD5OfMessageBody":"fae535c7f7c5687a1c3d8bc52288e33a","MD5OfMessageAttributes":"3ae3c4f59958e031d0d53af2d157e834", }, "message":"Message sent successfully to the SQS queue." }}` 응답 구문은 SQS send_message - Boto3 설명서를 참조하세요.
성공	부울	`success: true \| false`
오류 메시지	문자열	`"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""`

출력 필드

유형

예시

response

물체

{"statusCode":200, "payload":{"status":"success","data":{"MessageId":"e9b73a52-d018-4a73-9fcd-8efb682fba43","MD5OfMessageBody":"fae535c7f7c5687a1c3d8bc52288e33a","MD5OfMessageAttributes":"3ae3c4f59958e031d0d53af2d157e834", }, "message":"Message sent successfully to the SQS queue." }}

응답 구문은 SQS send_message - Boto3 설명서를 참조하세요.

성공

부울

success: true | false

오류 메시지

문자열

"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""

워크플로 예
name: sqs-send-message-test description: Sends a message to an SQS queue workflowInputs: arnRole: type: String steps: - name: aws_sqs_sendMessage_1 type: action action: aws.sqs.sendMessage version: '1' inputs: awsRoleArn: ${{ .workflowInputs.arnRole }} region: us-east-2 queueUrl: https://sqs.us-east-2.amazonaws.com/123456789012/workflow-test-queue messageBody: "This is a test message" messageAttributes: my_attribute_name_1: DataType: "String" StringValue: "my_attribute_value_1" my_attribute_name_2: DataType: "String" StringValue: "my_attribute_value_2" next: end

워크플로 예

name: sqs-send-message-test
description: Sends a message to an SQS queue
workflowInputs:
  arnRole:
    type: String
steps:
  - name: aws_sqs_sendMessage_1
    type: action
    action: aws.sqs.sendMessage
    version: '1'
    inputs:
      awsRoleArn: ${{ .workflowInputs.arnRole }}
      region: us-east-2
      queueUrl: https://sqs.us-east-2.amazonaws.com/123456789012/workflow-test-queue
      messageBody: "This is a test message"
      messageAttributes:
        my_attribute_name_1:
          DataType: "String"
          StringValue: "my_attribute_value_1"
        my_attribute_name_2:
          DataType: "String"
          StringValue: "my_attribute_value_2"
    next: end

지정된 대기열에서 하나 이상의 메시지를 검색합니다.

입력 필드	선택성	유형	예시
awsRoleArn	선택 과목	문자열	`arn:aws:iam::123456789012:role/my-workflow-role`
awsAccessKeyId	선택 과목	문자열	`${{ :secrets:<awsAccessKeyId> }}`
awsSecretAccessKey	선택 과목	문자열	`${{ :secrets:<awsSecretAccessKey> }}`
awsSessionToken	선택 과목	문자열	`${{ :secrets:<awsSessionToken> }}`
지역	필수의	문자열	`"us-east-2"`
대기열 URL	필수의	문자열	" `https://sqs.us-east-2.amazonaws.com/123456789012/my-queue` "
최대 메시지 수	선택 과목	Int	`10`
대기시간초	선택 과목	Int	`5`
가시성 시간 초과	선택 과목	Int	`123`
속성 이름	선택 과목	목록	`[ 'All'\|'Policy'\|'VisibilityTimeout'\|'MaximumMessageSize'\|'MessageRetentionPeriod'\|'ApproximateNumberOfMessages'\|'ApproximateNumberOfMessagesNotVisible'\|'CreatedTimestamp'\|'LastModifiedTimestamp'\|'QueueArn'\|'ApproximateNumberOfMessagesDelayed'\|'DelaySeconds'\|'ReceiveMessageWaitTimeSeconds'\|'RedrivePolicy'\|'FifoQueue'\|'ContentBasedDeduplication'\|'KmsMasterKeyId'\|'KmsDataKeyReusePeriodSeconds'\|'DeduplicationScope'\|'FifoThroughputLimit'\|'RedriveAllowPolicy'\|'SqsManagedSseEnabled', ]`
메시지 속성 이름	선택 과목	목록	`[ 'message_attribute_name', ],`
messageSystemAttributeNames	선택 과목	목록	`['SenderId', 'SentTimestamp']`
receiveRequestAttemptId	선택 과목	문자열	`"req-1234abcd"`

출력 필드	유형	예시
response	물체	`{"response":<aws api response> }` 응답 구문은 receive_message - Boto3 설명서를 참조하세요. (https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/sqs/client/receive_message.html)
성공	부울	`success: true \| false`
오류 메시지	문자열	`"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""`

출력 필드

유형

예시

response

물체

{"response":<aws api response> }

응답 구문은 receive_message - Boto3 설명서를 참조하세요. (https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/sqs/client/receive_message.html)

성공

부울

success: true | false

오류 메시지

문자열

"errorMessage": "SQS.Client.exceptions.QueueDoesNotExist: "The specified queue does not exist.""

name: sqs-receive-message-test
description: 'Receives a message from an SQS queue'
steps:
  - name: aws_sqs_receiveMessage_1
    type: action
    action: aws.sqs.receiveMessage
    version: '1'
    inputs:
      awsRoleArn: ${{ :secrets:awsRoleArn }}
      region: us-east-1
      queueUrl: https://sqs.us-east-1.amazonaws.com/123456789012/workflow-test-queue
      waitTimeSeconds: 5
      maxNumberOfMessages: 10
      messageAttributeNames: ['message_attribute_name'],

사용자의 편의를 위해 제공되는 기계 번역입니다.

전제 조건

AWS SQS 대기열에 메시지 보내기

AWS SQS 대기열에서 메시지를 수신합니다.

사용자의 편의를 위해 제공되는 기계 번역입니다.

AWS SQS 작업

전제 조건.css-21sua1{background:none;border:none;width:0;padding:0;}

AWS SQS 대기열에서 메시지를 수신합니다.

전제 조건