This document describes the current stable version of Kombu (5.3). 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)

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)

make_request(operation_name, params, queue_url, verb, callback=None)

Overide make_request to support different protocols.

botocore is soon going to change the default protocol of communicating with SQS backend from ‘query’ to ‘json’, so we need a special implementation of make_request for SQS. More information on this can be found in: https://github.com/celery/kombu/pull/1807.

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)