메세지를 Factory API로 전송하는 Lambda 구성 및 DLQ 추가

𝅺

Step 3 : 메시지를 Factory API로 전송하는 Lambda 구성 및 DLQ 추가

• 가용성을 높이기 위한 DLQ를 stock_queue에 연결
• stock_queue에 들어온 메시지를 소모하기 위한 stock_lambda 구성
  • 👉 stock-lambda 프로젝트 및 코드는 제공되지 않습니다. 여러분이 배운 방법을 활용하여 직접 람다 함수를 생성하세요. 람다 함수의 로그(CloudWatch)를 통해 stock_queue로부터 오는 메시지를 확인하고 SQS에 메시지가 삭제되었다면 성공입니다.
  • stock_queue에서 메시지가 사라지는 것과 stock_lambda에서 생성된 로그 확인

dlq 생성

기존 sqs > 편집 > 배달 못한 편지 대기열 활성화

stock_lambda 생성

블루프린트를 사용해서 메세지를 소비하는 람다 생성

console.log('Loading function');

exports.handler = async (event) => {
  //console.log('Received event:', JSON.stringify(event, null, 2));
  function delay(time) {
  return new Promise(resolve => setTimeout(resolve, time));
  }
  
  for (const { messageId, body } of event.Records) {
    console.log('SQS message %s: %j', messageId, body);
    
    // 딜레이 설정
    await delay(15000);
  }
  
  return `Successfully processed ${event.Records.length} messages.`;
};

람다 코드 수정( + dlq 테스트를 위한 딜레이 )