곧 AWS SDK for JavaScript(v2)에 대한 지원이 종료될 예정임을 알려드립니다. AWS SDK for JavaScript v3로 마이그레이션하실 것을 권장합니다. 마이그레이션 날짜, 추가 세부 정보 및 방법에 대한 자세한 내용은 링크된 공지 사항을 참조하세요.

Amazon SQS에서 DLQ(Dead Letter Queue) 사용

이 Node.js 코드 예제는 다음을 보여 줍니다.

시나리오

배달 못한 편지 대기열은 성공적으로 처리하지 못한 메시지를 다른 (소스) 대기열에서 보낼 수 있는 대기열입니다. 배달 못한 편지 대기열에서 이 메시지를 구분하고 격리하여 처리에 실패한 이유를 확인할 수 있습니다. 배달 못한 편지 대기열로 메시지를 보내는 각 소스 대기열을 개별적으로 구성해야 합니다. 여러 대기열은 단일 배달 못한 편지 대기열을 대상으로 삼을 수 있습니다.

이 예제에서는 Node.js 모듈을 사용하여 배달 못한 편지 대기열로 메시지를 라우팅합니다. Node.js 모듈은 SDK for JavaScript로 AWS.SQS 클라이언트 클래스의 다음 메서드를 사용하여 DLQ(Dead Letter Queue)를 사용합니다.

Amazon SQS DLQ(Dead Letter Queue)에 대한 자세한 내용은 Amazon Simple Queue Service 개발자 안내서의 Amazon SQS DLQ(Dead Letter Queue) 사용을 참조하세요.

사전 필수 작업

이 예제를 설정하고 실행하려면 먼저 이러한 작업들을 완료해야 합니다.

소스 대기열 구성

배달 못한 편지 대기열 역할을 하는 대기열을 생성한 후에는 다른 대기열이 처리되지 못한 메시지를 배달 못한 편지 대기열로 라우팅하도록 구성해야 합니다. 이렇게 하려면 배달 못한 편지 대기열로 사용할 대기열을 식별하는 리드라이브 정책을 지정하고 개별 메시지가 배달 못한 편지 대기열로 라우팅되기 전 최대 수신 수를 설정해야 합니다.

파일 이름이 sqs_deadletterqueue.js인 Node.js 모듈을 생성합니다. 위와 같이 SDK를 구성해야 합니다. Amazon SQS에 액세스하려면 AWS.SQS 서비스 객체를 생성합니다. 배달 못한 편지 대기열의 ARN과 maxReceiveCount의 값을 모두 지정하는 RedrivePolicy 파라미터를 포함하여 대기열 속성을 업데이트하는 데 필요한 파라미터를 포함하는 JSON 객체를 생성합니다. 또한 구성하고자 하는 URL 소스 대기열을 지정합니다. setQueueAttributes 메서드를 호출합니다.

// Load the AWS SDK for Node.js
var AWS = require("aws-sdk");
// Set the region
AWS.config.update({ region: "REGION" });

// Create the SQS service object
var sqs = new AWS.SQS({ apiVersion: "2012-11-05" });

var params = {
  Attributes: {
    RedrivePolicy:
      '{"deadLetterTargetArn":"DEAD_LETTER_QUEUE_ARN","maxReceiveCount":"10"}',
  },
  QueueUrl: "SOURCE_QUEUE_URL",
};

sqs.setQueueAttributes(params, function (err, data) {
  if (err) {
    console.log("Error", err);
  } else {
    console.log("Success", data);
  }
});

예제를 실행하려면 명령줄에서 다음을 입력합니다.

node sqs_deadletterqueue.js

이 샘플 코드는 GitHub에서 찾을 수 있습니다.