This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.

SQS Connection - kombu.asynchronous.aws.sqs.connection

Amazon SQS Connection.

class kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection(sqs_connection, debug=0, region=None, **kwargs)

Async SQS Connection.

add_permission(queue, label, aws_account_id, action_name, callback=None)

change_message_visibility(queue, receipt_handle, visibility_timeout, callback=None)

change_message_visibility_batch(queue, messages, callback=None)

create_queue(queue_name, visibility_timeout=None, callback=None)

delete_message(queue, receipt_handle, callback=None)

delete_message_batch(queue, messages, callback=None)

delete_message_from_handle(queue, receipt_handle, callback=None)

delete_queue(queue, force_deletion=False, callback=None)

get_all_queues(prefix='', callback=None)

get_dead_letter_source_queues(queue, callback=None)

get_queue(queue_name, callback=None)

get_queue_attributes(queue, attribute='All', callback=None)

get_queue_url(queue)

lookup(queue_name, callback=None)

receive_message(queue, queue_url, number_messages=1, visibility_timeout=None, attributes=('ApproximateReceiveCount',), wait_time_seconds=None, callback=None)

remove_permission(queue, label, callback=None)

send_message(queue, message_content, delay_seconds=None, callback=None)

send_message_batch(queue, messages, callback=None)

set_queue_attribute(queue, attribute, value, callback=None)