📌 Step 4 : 데이터베이스의 재고를 증가시키는 Lambda 함수 생성

• 데이터베이스의 재고를 증가시키는 Lambda 함수(stock-increase-lambda)를 배포
• stock_lambda에서 레거시 시스템(Factory API)에 제품 생산 요청

  • 위의 Factory API 문서를 활용하여, 코드를 작성해야 합니다.

  • stock_lambda 프로젝트에 npm install axios 명령으로 axios 라이브러리를 설치해야 합니다. axios는 node.js에서 HTTP 명령을 보내는 라이브러리입니다. (fetch와 유사)

    • 코드 맨 윗줄에 const axios = require('axios').default를 추가합니다.

  • 다음 코드를 활용하여 Factory API에 제품 생산을 요청하세요.

    const payload = {
      // TODO:
      // 어떤 형식으로 넣어야 할까요? Factory API 문서를 참고하세요.
      // 필요하다면 record.body를 활용하세요.
    }
    
     axios.post('<http://project3-factory.coz-devops.click/api/manufactures>', payload)
    .then(function (response) {
      console.log(response);
    })
    .catch(function (error) {
      console.log(error);
    });
    

  • Sales API에서 메시지를 SNS에 발행할 때 때 Factory API에 필요한 정보를 같이 넘겨야 합니다. Factory API에 맞게 params를 수정해야 할 것입니다.

  • 재고 없음 메시지 전송 → 일정 시간 이후 다시 요청 시 재고감소 작동 확인

  • Factory API 및 stock-increase-lambda가 반영된 최종 아키텍처를 그려봅시다.

////    /stock-lambda/serverless.yaml    ////

service: stock-lambda
frameworkVersion: '3'

provider:
  name: aws
  runtime: nodejs14.x
  region: ap-northeast-2

functions:
  producer:
    handler: index.consumer
    events:
      - sqs: arn:aws:sqs:ap-northeast-2:517061613095:no-stock-sqs

plugins:
  - serverless-lift

////    /stock-lambda/index.js    ////

const consumer = async (event) =>{

  for (const record of event.Records) {
    
    console.log(`body로 전달받은 데이터 확인 : ${record.body}`);
    const json = JSON.parse(record.body).MessageAttributes
    
    console.log(`필요 데이터 : ${JSON.stringify(json)}`);
    console.log(`요청자 : ${json.MessageAttributeRequester.Value}`);
    console.log(`물건 아이디 : ${json.MessageAttributeProductId.Value}`);
    console.log(`공장 아이디 : ${json.MessageAttributeFactoryId.Value}`);
    console.log(`수량 : ${json.MessageAttributeProductCnt.Value}`);   

  }
};

module.exports = {
  consumer,
};

AWS 콘솔에서 만든 람다함수를 삭제하고 동일하게 로컬에서 편리한 배포와 수정을 위해 sls로 생성

npm install axios

HTTP 명령을 보내기 위해 axios 라이브러리 설치

/////            sales-api/handler.js        /////

const serverless = require("serverless-http");
const express = require("express");
const app = express();
app.use(express.json())

const AWS = require("aws-sdk") // STEP 2
const sns = new AWS.SNS({ region: "ap-northeast-2" }) // STEP 2

const {
  connectDb,
  queries: { getProduct, setStock }
} = require('./database')

app.get("/product/donut", connectDb, async (req, res, next) => {
  const [ result ] = await req.conn.query(
    getProduct('CP-502101')
  )

  await req.conn.end()
  if (result.length > 0) {
    return res.status(200).json(result[0]);
  } else {
    return res.status(400).json({ message: "상품 없음" });
  }
});

app.post("/checkout", connectDb, async (req, res, next) => {
  const [ result ] = await req.conn.query(
    getProduct('CP-502101')
  )
  if (result.length > 0) {
    const product = result[0]
    if (product.stock >= 0 && product.stock >= req.body.MessageAttributeProductCnt) {
      await req.conn.query(setStock(product.product_id, product.stock - req.body.MessageAttributeProductCnt))
      return res.status(200).json({ message: `구매 완료! 남은 재고: ${product.stock - req.body.MessageAttributeProductCnt}`});
    }
    else {
      await req.conn.end()

////
      const now = new Date().toString()
      const message = `도너츠 재고가 없습니다. 제품을 생산해주세요! \\n메시지 작성 시각: ${now}`
      const params = {
        Message: message,
        Subject: '도너츠 재고 부족',
        MessageAttributes: {
          MessageAttributeProductId: {
            StringValue: product.product_id,
            DataType: "String",
          },
          MessageAttributeFactoryId: {
            StringValue: req.body.MessageAttributeFactoryId,
            DataType: "String",
          },
          MessageAttributeRequester: {
            StringValue: req.body.MessageAttributeRequester,
            DataType: "String",
          },
          MessageAttributeProductCnt: {
            StringValue: req.body.MessageAttributeProductCnt,
            DataType: "String",
          }
        },
        TopicArn: process.env.TOPIC_ARN
      }

      const result = await sns.publish(params).promise()
////

      return res.status(200).json({ message: `구매 실패! 남은 재고: ${product.stock}`});
    }
  } else {
    await req.conn.end()
    return res.status(400).json({ message: "상품 없음" });
  }
});

app.use((req, res, next) => {
  return res.status(404).json({
    error: "Not Found",
  });
});

module.exports.handler = serverless(app);
module.exports.app = app;

////       /stock-lambda/index.js          ////

const axios = require('axios').default

const consumer = async (event) =>{

  for (const record of event.Records) {
    
    console.log(`body로 전달받은 데이터 확인 : ${record.body}`);
    const json = JSON.parse(record.body).MessageAttributes
    
    console.log(`필요 데이터 : ${JSON.stringify(json)}`);
    console.log(`요청자 : ${json.MessageAttributeRequester.Value}`);
    console.log(`물건 아이디 : ${json.MessageAttributeProductId.Value}`);
    console.log(`공장 아이디 : ${json.MessageAttributeFactoryId.Value}`);
    console.log(`수량 : ${json.MessageAttributeProductCnt.Value}`);    
    
    const payload = {
      MessageGroupId: 'stock-arrival-group',
      MessageAttributeProductId: json.MessageAttributeProductId.Value,
      MessageAttributeProductCnt: json.MessageAttributeProductCnt.Value,
      MessageAttributeFactoryId: json.MessageAttributeFactoryId.Value,
      MessageAttributeRequester: json.MessageAttributeRequester.Value,
      CallbackUrl: '<https://hk6rw1m3qg.execute-api.ap-northeast-2.amazonaws.com/product/donut>',
    };    

    axios.post('<http://project3-factory.coz-devops.click/api/manufactures>', payload)
    .then(function (response) {
      console.log(response);
    })
    .catch(function (error) {
      console.log(error);
    });

  }
};

module.exports = {
  consumer,
};

API 문서 참고하여 입력값과 출력값이 API문서와 같이 나올 수 있도록 코드 수정