📌 Tutorial - Step 2

sqs 프로젝트 생성

Untitled

🚨 ( issues 3 ) 권한 오류 ⭕

serverless.yaml 파일 리전 추가

provider:
  name: aws
  runtime: nodejs18.x

+  region: ap-northeast-2

index.js 파일 수정

const { SQSClient, SendMessageCommand } = require("@aws-sdk/client-sqs");
const sqs = new SQSClient();

const producer = async (event) => {
  let statusCode = 200;
  let message;

  if (!event.body) {
    return {
      statusCode: 400,
      body: JSON.stringify({
        message: "No body was found",
      }),
    };
  }

  try {
    await sqs.send(new SendMessageCommand({
      QueueUrl: process.env.QUEUE_URL,
      MessageBody: event.body,
      MessageAttributes: {
        AttributeName: {
          StringValue: "Attribute Value",
          DataType: "String",
        },
      },
    }));

    message = "Message accepted!";
  } catch (error) {
    console.log(error);
    message = error;
    statusCode = 500;
  }

  return {
    statusCode,
    body: JSON.stringify({
      message,
    }),
  };
};

/// 수정 부분 ///

const consumer = async (event) => {
  for (const record of event.Records) {
    console.log("Message Body: ", record.body);

    // TODO: Step 1을 참고하여, +1 를 하는 코드를 넣으세요
    if (record.body) {
      let body = JSON.parse(record.body);
      inputValue = parseInt(body);
      outputValue = inputValue + 1;
    }

    const message = `메시지를 받았습니다. 입력값: ${inputValue}, 결과: ${outputValue}`
    console.log(message)

  }
};

/// 수정 부분 ///

module.exports = {
  producer,
  consumer,
};

클라우드워치 입력값 확인

Untitled