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

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

Amazon SQS Connection.

class kombu.async.aws.sqs.connection.AsyncSQSConnection(aws_access_key_id=None, aws_secret_access_key=None, is_secure=True, port=None, proxy=None, proxy_port=None, proxy_user=None, proxy_pass=None, debug=0, https_connection_factory=None, region=None, *args, **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, message, 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=u'', callback=None)

get_dead_letter_source_queues(queue, callback=None)

get_queue(queue_name, callback=None)

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

lookup(queue_name, callback=None)

receive_message(queue, number_messages=1, visibility_timeout=None, attributes=None, 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)