This document describes the current stable version of Kombu (4.5). For development docs, go here.

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

Amazon SQS Connection.

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

Async SQS Connection.

add_permission(queue, label, aws_account_id, action_name, callback=None)[source]
change_message_visibility(queue, receipt_handle, visibility_timeout, callback=None)[source]
change_message_visibility_batch(queue, messages, callback=None)[source]
create_queue(queue_name, visibility_timeout=None, callback=None)[source]
delete_message(queue, receipt_handle, callback=None)[source]
delete_message_batch(queue, messages, callback=None)[source]
delete_message_from_handle(queue, receipt_handle, callback=None)[source]
delete_queue(queue, force_deletion=False, callback=None)[source]
get_all_queues(prefix='', callback=None)[source]
get_dead_letter_source_queues(queue, callback=None)[source]
get_queue(queue_name, callback=None)[source]
get_queue_attributes(queue, attribute='All', callback=None)[source]
get_queue_url(queue)[source]
lookup(queue_name, callback=None)
receive_message(queue, number_messages=1, visibility_timeout=None, attributes=None, wait_time_seconds=None, callback=None)[source]
remove_permission(queue, label, callback=None)[source]
send_message(queue, message_content, delay_seconds=None, callback=None)[source]
send_message_batch(queue, messages, callback=None)[source]
set_queue_attribute(queue, attribute, value, callback=None)[source]