본 문서에서는 Serverless Event-Driven Architecture에 기반하여 책 읽어주는 서비스(Story Time)을 구현하는 과정을 설명합니다.

책 읽어주는 서비스(Storytime)는 이미지에서 텍스트를 추출하는 AWS Rekognition과 텍스트를 음성으로 변환하는 AWS Polly을 이용하여 구현됩니다. 이러한 AI/ML기반의 AWS 서비스를 사용하여 효율적인 시스템 아키텍처를 설계하기 위하여 AWS Lambda와 AWS SQS를 적극적으로 사용합니다. 이와 같은 AWS Serverless Architecture는 초기 투자가 없어 비용 효율적이며, auto scaling을 통해 트래픽 변화에 대해서도 적절히 대응할 수 있습니다. 아래 그림은 Story Time의 Severless Event-Driven Architecture에 구조에 대해 기술하고 있습니다.

주요 사용 시나리오는 아래와 같습니다.

1. 사용자가 동화책과 같은 읽고자 하는 책을 카메라로 찍습니다.

2. 이미지를 RESTful API를 이용해 API Gateway를 통해 업로드를 합니다. 통신 프로토콜은 https를 이용합니다. 이후, Lambda for upload는 S3에 파일을 저장하고, Bucket 이름과 Key와 같은 정보를 event로 SQS에 전달합니다.

3. SQS의 event는 Lambda for Rekognition에 전달되고, 이 정보는 AWS Rekognition를 통해 JSON 형태의 텍스트 정보를 추울합니다.

4. 텍스트 정보는 다시 SQS를 통해 Lambda for Polly로 전달되는데, JSON 형식의 event에서 텍스트틑 추출하여, AWS Polly를 통해 음성파일로 변환하게 됩니다.

5. 음성파일은 S3에 저장되는데, Lambda for Polly를 이 정보를 CloudFront를 통해 외부에 공유할 수 있는 URL로 변환후, AWS SNS를 통해 사용자에게 이메일 또는 Slack으로 전달합니다.

Sequence Diagram에서는 기본동작 시나리오, 중복처리, Retrive API에 대해 Sequence diagram으로 설명합니다.

1. Lambda for upload 구현

AWS Lambda를 이용해 파일을 업로드하는 코드를 Node.js를 이용해 구현 합니다.

2. API Gateway 구현

RESTful API를 구현하기 위하여 Endpoint로 API Gateway를 구현합니다.

3. Lambda for Rekognition 구현

이미지에서 텍스트를 추출합니다.

4. S3 구현

Amazon S3를 사용하기 위한 Bucket을 생성합니다.

5. CloudFront 구현

컨텐츠를 공유하기 위한 CDN으로 CloudFront를 구현합니다.

6. Lambda for Polly 구현

AWS Polly를 이용해 텍스트틀 mp3로 변환하여 S3에 저장합니다.

7. Amazon SNS 구현

업로드한 파일을 다운로드 링크를 email로 전달합니다.

8. Amazon SQS 구현

각 서비스는 SQS를 통해 버퍼링 됩니다.

9. DynamoDB 설정

DynamoDB에는 파일의 중복을 판단하는 정보와 event에 대한 정보가 저장됩니다.

10. Lambda for Retrieve 구현

이미지 파일 업로드 Client에서 Polling 하거나 사용자 Action으로 조회시 사용하는 '/retrieve' API를 위한 Lambda를 정의 합니다.

11. Slack으로 전송하기

SNS 통한 이메일 뿐 아니라 Slack으로도 결과를 메시지로 받기를 원하는 경우에 설정합니다.

12. 테스트 및 결과

파일을 업로드하여 테스트틑 하는 방법과 예상되는 결과를 검토합니다.

참고: API Gateway Log 설정은 API Gataway에 대한 로그를 CloudWatch에서 확인하기 위한 설정 방법입니다.

13. Bulk 입력 처리

이미지 파열을 여러개 올려서 한꺼번에 결과를 얻고자 하는 경우에는 Bulk API를 정의하여 사용합니다.

14. CDK 사용

장기적으로 인프라를 관리하기 위해서는 IaC(Infrastructure as Code) 툴이 필요합니다. 여기서는 Amazon CDK를 이용해 순쉽게 인프라를 관리하는 방법에 대해 소개 합니다.

15. Cognito 설정

Cognito를 사용하기 위해서는 Client가 Web page접속시 access token을 획득하여, api 호출시마다 "Authorization"헤더에 access token을 전달해 주어야 합니다.

16. Grafana설정

Dashboard 작성을 위해 Amazon Grafana를 설정합니다.

관련된 코드들은 아래를 참조 바랍니다.

Lambda-upload

Lambda-rekognition

Lambda-polly

Lambda-retrieve

Lambda-bulk

Lambda-opensearch

Lambda-slack

Textract의 경우에 Rekognition보다 더 많은 텍스트를 추출할 수 있는 장점이 있어 참고로 정리했습니다.

Textract