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

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

Amazon SQS Connection.

class kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection(sqs_connection, debug=0, region=None, message_system_attribute_names=None, message_attribute_names=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, protocol_params=None)

    Override make_request to support different protocols.

    botocore has changed 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.

    protocol_params: Optional[dict[str, dict]] of per-protocol additional parameters.

      Supported for the SQS query to json protocol transition.

  receive_message(queue, queue_url, 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)