Using queues in Amazon SQS¶
This Python example shows you how to:
Get a list of all of your message queues
Obtain the URL for a particular queue
Create and delete queues
The scenario¶
In this example, Python code is used to work with queues. The code uses the AWS SDK for Python to use queues using these methods of the AWS.SQS client class:
For more information about Amazon SQS messages, see How Queues Work in the Amazon Simple Queue Service Developer Guide.
List your queues¶
The example below shows how to:
List queues using list_queues.
Example¶
import boto3
# Create SQS client
sqs = boto3.client('sqs')
# List SQS queues
response = sqs.list_queues()
print(response['QueueUrls'])
Create a queue¶
The example below shows how to:
Create a queue using create_queue.
Example¶
import boto3
# Create SQS client
sqs = boto3.client('sqs')
# Create a SQS queue
response = sqs.create_queue(
QueueName='SQS_QUEUE_NAME',
Attributes={
'DelaySeconds': '60',
'MessageRetentionPeriod': '86400'
}
)
print(response['QueueUrl'])
Get the URL for a queue¶
The example below shows how to:
Get the URL for a queue using get_queue_url.
Example¶
import boto3
# Create SQS client
sqs = boto3.client('sqs')
# Get URL for SQS queue
response = sqs.get_queue_url(QueueName='SQS_QUEUE_NAME')
print(response['QueueUrl'])
Delete a queue¶
The example below shows how to:
Delete a queue using delete_queue.
Example¶
import boto3 # Create SQS client sqs = boto3.client('sqs') # Delete SQS queue sqs.delete_queue(QueueUrl='SQS_QUEUE_URL')