1. Simple Queue Service 정의
SQS란 여러 호출을 하나의 큐에 담아서 다른 곳에 보낼 수 있게 해주는 서비스이다. SQS는 전송, 수신, 삭제 3가지 기능을 제공한다.
SQS에는 세 가지 주체가 있다.
- Producer(데이터 송신자)
- SQS(Queue)
- Consumer(데이터 수신자)
아래와 같이 여러 클라이언트가 호출을 할 때 하나씩 작업을 처리하기 보단, SQS의 queue에서 데이터를 한 번에 모으고 수신자에서 처리하는 것이 훨씬 효율적이다.
SQS 아키텍쳐
2. SQS 생성
1) 대기열 생성
- SQS 검색 후 대기열 생성 클릭
- 대기열 유형: 필자는 FIFO로 사용해서 FIFO 사용
- 이름: 대기열 유형을 FIFO로 선택했을 때 마지막에 .fifo를 붙여주어야 함
- 액세스 정책: 기본으로 설정하면 JSON > Action > SQS > * 로 되어 있다. 이는 SQS에서 전송, 수신, 삭제 등 모든 기능을 수행할 수 있게 한다는 것이다. 기본으로 설정한다.
- 맨 아래의 [대기열 생성] 버튼을 클릭한다.
2) SQS 편집
- 생성 후 나온 페이지 중앙 윗 부분에 [편집]을 클릭한다.
- [콘텐츠 기반 중복 제거]를 클릭하여 활성화 해준다.
3. Lambda 생성
1) 함수 생성
- 람다 함수 생성을 한다. 생성 할 때는 따로 설정할 것이 없다.
2) 권한 추가
- 생성한 함수에 클릭하여 들어간다.
- [구성] - [권한] - 실행 역할의 [역할 이름]을 클릭한다.
- [권한 정책] 안에 있는 [권한 추가]를 클릭하여 [정책 연결]을 클릭한다.
- [기타 권한 정책] 아래에 있는 검색 창에서 "SQS"를 검색한다.
- "AmazonSQSFullAccess"가 나오면 왼쪽 체크박스를 클릭 후, 아래에 있는 [정책 연결]을 클릭한다.
3) SQS 메시지 전송 코드
import json
import os
import boto3
import logging
from botocore.exceptions import ClientError
def lambda_handler(event, context):
_params = {'message': "hello"}
msg_body = json.dumps(_params)
msg = send_sqs_message(os.environ['SQS_QUEUE'], msg_body)
return msg
def send_sqs_message(sqs_queue_url, msg_body):
sqs_client = boto3.client('sqs')
try:
msg = sqs_client.send_message(QueueUrl=sqs_queue_url,
MessageBody=msg_body,
MessageGroupId="ikaria")
except ClientError as e:
logging.error(e)
return None
return msg- boto3: AWS Service와 연결할 수 있게 해주는 라이브러리
- sqs_client = boto3.client('sqs') :
>> boto3를 사용해서 sqs 서비스에 접근할 수 있는 client 객체 생성
- msg = sqs_client.send_message(QueueUrl=sqs_queue_url,
MessageBody=msg_body,
MessageGroupId="ikaria")
>> QueueUrl = {SQS 엔드포인트 작성}
MessageBody = {보낼 메시지}
MessageGroupId = {FIFO로 대기열을 설정했을 경우 꼭 작성해야 함}- [함수] - [테스트] 를 클릭하면 SQS 대기열에 메시지가 들어간다.
- [SQS] - [대기열] - [생성한 대기열] - 오른쪽 위의 [메시지 전송 및 수신] 선택
- 만약 메시지가 잘 발송되었다면 아래 [메시지 수신] - [사용 가능한 메시지]가 1로 되어 있을 것이다.
- [메시지 풀링]을 클릭하면 아래 [메시지]에 메시지가 나온다.
