import boto3
sqs = boto3.client('sqs', region_name='us-west-2')
response = sqs.receive_message(
QueueUrl='SQS_QUEUE_URL',
MaxNumberOfMessages=5
)
2.使用循环来多次调用sqs.receive_message方法。例如,使用while循环,每次获取一个消息,直到获取到所需数量的消息为止。
import boto3
sqs = boto3.client('sqs', region_name='us-west-2')
messages = []
while len(messages) < 5:
response = sqs.receive_message(
QueueUrl='SQS_QUEUE_URL',
MaxNumberOfMessages=1
)
messages.extend(response.get('Messages', []))
其中,'SQS_QUEUE_URL'是你的SQS队列的URL。
上一篇:AWSSES破坏邮件样式