[go] Go 언어를 사용하여 AWS SQS 큐로부터 메시지 수신하기
1. AWS SDK 설치
먼저 Go 언어에서 AWS 서비스를 사용하기 위해 aws-sdk-go
를 설치해야 합니다.
go get github.com/aws/aws-sdk-go
2. AWS 접속 설정
import (
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/aws/session"
"github.com/aws/aws-sdk-go/service/sqs"
)
sess := session.Must(session.NewSession(&aws.Config{
Region: aws.String("AWS_Region"),
}))
svc := sqs.New(sess)
3. 메시지 받아오기
params := &sqs.ReceiveMessageInput{
QueueUrl: aws.String("SQS_Queue_URL"),
AttributeNames: []*string{
aws.String(sqs.MessageSystemAttributeNameSentTimestamp),
},
MaxNumberOfMessages: aws.Int64(10),
MessageAttributeNames: []*string{
aws.String("All"),
},
VisibilityTimeout: aws.Int64(60),
WaitTimeSeconds: aws.Int64(20),
}
resp, err := svc.ReceiveMessage(params)
if err != nil {
// 에러 처리
}
위의 코드에서 AWS_Region
을 실제 AWS 리전 이름으로, SQS_Queue_URL
을 사용하려는 SQS 큐의 URL로 대체하세요.
이제 Go 언어로 AWS SQS 큐로부터 메시지를 성공적으로 수신할 수 있습니다. 여기서는 메시지를 수신하는 기본적인 방법을 안내했지만, 이를 활용하여 원하는 대로 메시지를 처리하고 응용 프로그램을 개발할 수 있습니다.
참고 자료:
이제 Go 언어를 사용하여 AWS SQS 큐로부터 메시지를 수신하는 방법을 알아보았습니다.