반응형
SNS를 통해서 SQS에 메시지가 있다.
그러니까 SQS 안에 있는 메시지를 출력해보자!
sess := session.Must(session.NewSessionWithOptions(session.Options{
SharedConfigState: session.SharedConfigEnable,
}))
timeout := int64(5)
queueURL := "sqs 주소"
svc := sqs.New(sess)
msgResult, err := svc.ReceiveMessage(&sqs.ReceiveMessageInput{
AttributeNames: []*string{
aws.String(sqs.MessageSystemAttributeNameSentTimestamp),
},
MessageAttributeNames: []*string{
aws.String(sqs.QueueAttributeNameAll),
},
QueueUrl: queueURL,
MaxNumberOfMessages: aws.Int64(1),
VisibilityTimeout: timeout,
})
if err != nil {
return nil, err
}
}
msgResult 안에 다양한 정보 중에 메시지 내용이 있다.
*msgResult.Messages[0].Body
바디 값안에 있는 정보
{ "Type" : "Notification",
"MessageId" : "3da6fe1a-c689-5d83-b040-a310338cc23c",
"SequenceNumber" : "10000000000000037000",
"TopicArn" : "",
"Message" : "메시지 내용입니다.",
"Timestamp" : "2023-06-20T00:28:53.349Z",
"UnsubscribeURL" : "" }
MaxNumberOfMessages *int64 `type:"integer"`
*msgResult.Messages[0].Body 이 코드를 보면 메시지는 배열이다. 배열의 개수를 설정할 수 있다.
MaxNumberOfMessages *int64 `type:"integer"`
최소 1개에 최대 10개까지 설정할 수 있다. 한번에 메시지를 최대 10개까지 가져올 수 있다.
# 참조
https://docs.aws.amazon.com/ko_kr/sdk-for-go/v1/developer-guide/sqs-example-receive-message.html
# 이슈
https://github.com/YooGenie/receive-message-service/issues/17
반응형
'사이드 프로젝트 > Amazon SQS' 카테고리의 다른 글
[Amazon SQS] SQS에서 메시지를 받으면 자동 삭제가 되는지? (0) | 2023.06.23 |
---|---|
[Amazon SQS] 한번 SQS를 부를 때 여러개의 메시지가 오나? (0) | 2023.06.22 |
[Amazon SNS] SNS로 메시지 보내기 (0) | 2023.06.20 |
[Amazon SNS] SNS에서 메시지 보낼 때 나는 에러(error) 해결책 (0) | 2023.06.19 |
[Amazon SNS] SNS와 SQS 연결하는 방법 (0) | 2023.06.15 |