채팅 서비스 레퍼런스 분석3. Deploying a Group Chat App on a Serverless Architecture

[tonykang22]

Deploying a Group Chat App on a Serverless Architecture

• Reference

서버리스의 장점

• 서버리스 아키텍쳐는 사람이 직접 개입하지 않고도 확장이 가능한 인프라이며, 유휴 리소스와 관련된 비용은 거의 발생하지 않는다.
• 손꼽히는 장점은 다음과 같다.
  • 비용 절감
  • 서버 관리 불필요
  • 낮은 latency
  • 빠른 배포
  • 향상된 속도

서버리스 구축을 위해 필요한 서비스

• Amazon S3
• Amazon API Gateway
  • REST and WebSocket
• Amazon Lambda
  • Python
• Dynamo DB
• CloudFront
• Route 53

Amazon S3

• HTML, JS, CSS 등의 프론트 엔드 파일을 저장

Amazon API Gateway

• 모든 API 호출을 수신하고 실행하는데 필요한 다양한 서비스를 집계하고 적절한 결과를 반환하는 리버스 프록시 역할
• 이를 사용하여 REST API 및 WebSocket을 생성

Amazon Lambda

• Lambda를 통해 핵심 로직을 실행하고, 다른 AWS 서비스와 상호작용

DynamoDB

• NoSQL 데이터베이스로 채팅 앱의 영구 데이터를 저장
• 파티션키와 정렬키 개념 존재
  • 파티션키 : 파티션을 특정하는 기준 값
  • 정렬키 : 파티션 내에서 정렬하는 기준 값
  • Ref : Amazon DynamoDB

• 테이블 : chat_messages
  • 파티션키 : group_id
  • 정렬키 : date_time
• 테이블 : chat_groups
  • 파티션키 : group_id
• 테이블 : chat_members
  • 파티션키 : connection_id
  • 웹소켓 연결로 생성되는 고유한 ID 값
  • 정렬키 : member_username
  • 글로벌 보조 인덱스 : group_id(group_id-index)

CloudFront

• S3의 데이터를 사용자에게 효율적으로 배포

흐름

• Ref : https://github.com/davykiash/group-chat-app

Retrieving the list of groups

• 사용자에게 사용할 수 있는 채팅 그룹을 전달

"""

    Author | https://github.com/davykiash

"""

import os
import json
import boto3
import botocore
import requests
from datetime import datetime
from botocore.exceptions import ClientError
from boto3.dynamodb.conditions import Key

DYNAMODB_AWS_KEY = os.getenv('DYNAMODB_AWS_KEY')
DYNAMODB_AWS_SECRET = os.getenv('DYNAMODB_AWS_SECRET')
DYNAMODB_AWS_ENDPOINT = os.getenv('DYNAMODB_AWS_ENDPOINT')

def my_handler(event, context):
    # body = json.loads(event["body"])

    # store in dynamodb chat_messages user has joined
    list_of_groups = get_all_groups()
    if list_of_groups:

        return {
            'isBase64Encoded': False,
            'statusCode': 200,
            'headers': {"status": "success"},
            'body': json.dumps(list_of_groups)
        }

    else:
        return {
            'statusCode': 200,
            'body': "Connection Failed"
        }

def get_all_groups(dynamodb=None):
    if not dynamodb:
        dynamodb = boto3.resource('dynamodb',
                                  aws_access_key_id=DYNAMODB_AWS_KEY,
                                  aws_secret_access_key=DYNAMODB_AWS_SECRET,
                                  endpoint_url=DYNAMODB_AWS_ENDPOINT)

    table = dynamodb.Table('chat_groups')

    try:
        response = table.scan()
    except ClientError as e:
        print(e.response['Error']['Message'])
    else:
        if 'Items' in response.keys():
            return response['Items']
        else:
            return None

Joining and sending messages to all active members in the group.

• 사용자 가입
  • APIWebSocket에서 새 connection_id 생성
  • Lambda의 onConnection, getMessages 호출
• 메시지 전송
  • Lambda의 sendMessage 호출
  • 구성원들에게 전송
  • 나중에 참조할 수 있도록 테이블에 저장

Leave chat

• WebSocket에서 onDisconnect 호출
  • Lambda의 chatOnDisconnect 호출
  • chat_members : connection_id 제거