괴발개발 성장기

사이드 프로젝트/Amazon SQS

[Amazon SQS] SNS를 통해 FIFO방식으로 SQS에 메시지 보내기

지니유 2022. 11. 15. 22:50
반응형

# 배경

이메일 아니라 큐에 메시지를 보내야 했다.

1)  FIFO 방식이 아닌 표준방식 SNS만들고 SQS 연결했다. 이 때 메시지가 잘 보내졌다.

2) SNS에서 FIFO방식으로 만들고 FIFO방식의 SQS도 만들어서 연결 시켰다. 그리고 메시지를 보냈다.

3) MessageGroupId가 필요하다고 한다. 정확히 MessageGroupId 의미를 알지도 못했다. 

4) MessageGroupId에 임의 값을 넣었다.

 

# 코드

SQS에 메시지를 넣는 코드이다.

func SendMessage(sess *session.Session, queueURL *string) error {
	svc := sqs.New(sess)

	_, err := svc.SendMessage(&sqs.SendMessageInput{
		MessageGroupId: aws.String("12345"),
		MessageBody:    aws.String("테스트입니다."),
		QueueUrl:       queueURL,
	})

	if err != nil {
		return err
	}

	return nil
}

# 이미지

메시지를 보내면 aws에 가서 확인할 수 있다.

sqs에 메시지 하나 있다.

# 결론

다이렉트로 SQS에 값을 넣는데 SNS는 무슨 상관이 있을까? 그래서 우선 SNS는 생각하지 않고 SQS에 메시지를 넣는 것만 했다. 

다음 미션은 SQS에 있는 메시지를 뻬오는 서비스를 만들어야 한다.

 

# 참고

https://docs.aws.amazon.com/sdk-for-go/v1/developer-guide/using-sns-with-go-sdk.html

 

Amazon SNS Examples Using the AWS SDK for Go - AWS SDK for Go (version 1)

Thanks for letting us know this page needs work. We're sorry we let you down. If you've got a moment, please tell us how we can make the documentation better.

docs.aws.amazon.com

 

반응형