使用AWS SDK for Python (Boto3) API中的batch_receive_message()方法。该方法允许一次最多返回10条消息,并且可以通过设置MaxNumberOfMessages参数来控制返回的消息数。 示例代码:
import boto3
sqs = boto3.client('sqs', region_name='us-east-1')
queue_url = sqs.get_queue_url(QueueName='my-queue')['QueueUrl']
response = sqs.receive_message( QueueUrl=queue_url, MaxNumberOfMessages=10 )
for message in response['Messages']: # Print the message body print(message['Body'])
上一篇:AWSSQS监听vs轮询