🔥 TIL - Day 44

📌 Flask API 서버 EB에서 Lambda로 이사가기

일단 오늘은 인덱스 페이지에서 외부 API를 호출해서 리스팅하는 API를 Lambda로 옮기는 작업을 했다.

aws sam을 사용했는데 sam에 대해 간단하게 알아보자.

SAM (Serverless Application Model)
sam은 서버리스 애플리케이션을 보다 쉽게 관리할 수 있게 AWS가 제공해주는 프레임워크이다. sam을 사용하기 전에 우리는 직접 API 코드를 작성하고 필요한 모듈을 함께 압축해서 미리 생성한 Lambda 함수에 올려줬었다.
SAM을 사용하면 코드 수준에서 이런 일련의 작업에 대한 자동화 설정을 할 수 있다. (IoC, Infrastructure as Code)

음.. 근데 솔직히 간단한 API는 그냥 직접 올리는 게 더 편하지 않을까? 라는 생각이 들긴 한다.. ㅎ

하지만 코드로 설정할 수 있다는 것은 설정 자체를 재사용할 수 있다는 것이니 그냥 쓰는게 나중을 위해서 더 좋을 것 같다. 잘 써보자.

sam 을 사용할려면 aws-cli와 sam-cli가 설치되어야 한다.

macos 기준

brew install awscli

brew tap aws/tap
brew install aws-sam-cli

📌 프로젝트 생성

이제 sam 프레임워크 프로젝트를 하나 생성한다.

sam init

이런 디렉토리 구조가 보일 것이다.
aws sam은 설정파일을 통해 서버리스 애플리케이션을 관리한다고 했다.
그 설정파일이 template.yaml 이다.

일단 자세한 설정은 차차 필요할 때 찾아보는 걸로 하고 배포에 반드시 필요한 부분만 살펴보자. (주석 주석)

Resources:
  # HelloWorld API
  HelloWorldFunction:
    Type: AWS::Serverless::Function 
    Properties:
      CodeUri: hello_world/ # API가 있는 디렉토리명
      Handler: app.lambda_handler # 핸들러 함수명 (API접근시 실행될 함수)
      Runtime: python3.8
      Architectures:
        - x86_64
      Events:
        HelloWorld:
          Type: Api 
          # APIGateway엔드포인트/hello  <-- 이게 API의 엔드포인트가 되는 것
          Properties: # API Gateway에 대한 설정
            Path: /hello # HTTP 경로
            Method: get # HTTP Method

그럼 이제 API에 대한 설정을 해주자.
아직 연습단계라 VPC 설정은 해주지 않았다.

  TodayLawListFunction:
    Type: AWS::Serverless::Function 
    Properties:
      CodeUri: tl_list/
      Handler: app.lambda_handler
      Runtime: python3.8
      Architectures:
        - x86_64
      Events:
        TodayLawList:
          Type: Api 
          Properties:
            Path: /laws
            Method: get

API 코드
event 객체로 쿼리스트링을 받을 때 null 체크가 힘들다..
직접 if문으로 null체크를 하려고 queryStringParameters로 접근한 순간 널 에러를 발생시킨다.

그래서 Front 단에서 빈 값을 던져주는 걸로 수정했다.
이런식으로 ㅠㅠ

$.ajax({
        type: "GET",
        url: `${api_url}/laws?offset=${offset}&query=&proposer=&condition=법안명`,

별로다..

def lambda_handler(event, context):
    try:
        query = event['queryStringParameters']['query']
        proposer_name = event['queryStringParameters']['proposer']
        condition = event['queryStringParameters']['condition']
        pIndex = event['queryStringParameters']['offset']

        #== 검색조건이 없는 경우 ==#
        if query is None and condition is None:
            data = requests.get(
                f'https://open.assembly.go.kr/portal/openapi/nzmimeepazxkubdpn?Key={api_key}&Type={type}&AGE={age}&pIndex={pIndex}&pSize=10')
        #== 법안명으로 검색 ==#
        elif condition == '법안명':
            url = f'https://open.assembly.go.kr/portal/openapi/nzmimeepazxkubdpn?Key={api_key}&Type={type}&AGE={age}&BILL_NAME={query}&pIndex={pIndex}&pSize=10'
            query = encode_querystring(url)

            data = requests.get('https://open.assembly.go.kr/portal/openapi/nzmimeepazxkubdpn?' + query)
        #== 법안발의 제안자명으로 검색==#
        elif condition == '제안자':
            url = f'https://open.assembly.go.kr/portal/openapi/nzmimeepazxkubdpn?Key={api_key}&Type={type}&AGE={age}&PROPOSER={proposer_name}&pIndex={pIndex}&pSize=10'
            query = encode_querystring(url)

            data = requests.get('https://open.assembly.go.kr/portal/openapi/nzmimeepazxkubdpn?' + query)

        data = data.json()
        total_count = data['nzmimeepazxkubdpn'][0]['head'][0]['list_total_count']
        data = data['nzmimeepazxkubdpn'][1]['row']

        response = []
        response.append({'total_count':total_count})
        for d in data:
            names = d['PUBL_PROPOSER']
            names = get_other_proposer(names)
            response.append({
                'id':d['BILL_ID'],
                'title':d['BILL_NAME'],               # 법안제목
                'proposer_name':d['RST_PROPOSER'],    # 대표제안자
                'proposer_names':names,               # 대표제안자 외 제안자
                'date':d['PROPOSE_DT'],               # 발의 날짜
                'url':d['DETAIL_LINK'],               # 상세내용 크롤링 link
                'total_count':total_count
            })

        body = json.dumps(response)

        return {
            "statusCode": 200,
            'headers': {
                'Access-Control-Allow-Headers': 'Content-Type',
                'Access-Control-Allow-Origin': '*',
                'Access-Control-Allow-Methods': 'OPTIONS,POST,GET,DELETE'
            },
            "body": body
        }
    except Exception as e:
        print(e)
        return {
            "statusCode": 500,
            # Cross Origin처리
            'headers': {
                'Access-Control-Allow-Headers': 'Content-Type',
                'Access-Control-Allow-Origin': '*',
                'Access-Control-Allow-Methods': 'GET'
            },
            "body": json.dumps({
                "message": "fail",
            }),
        }

그럼 준비는 끝났으니 빌드 / 배포를 해준다.

sam build 

sam deploy [--guided]

HelloWorld API 까지 총 2개 Lambda 함수가 생성된다.

Lambda 함수의 트리거에 설정된 API Gateway를 보면 우리가 설정한 대로 엔드포인트가 설정된 것을 확인할 수 있다.

로컬에서 리스팅 API 테스트!