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

# SQS Queues - `kombu.asynchronous.aws.sqs.queue`

Amazon SQS queue implementation.

class kombu.asynchronous.aws.sqs.queue.AsyncQueue(connection=None, url=None, message_class=<class 'kombu.asynchronous.aws.sqs.message.AsyncMessage'>)

  Async SQS Queue.

  add_permission(label, aws_account_id, action_name, callback=None)
  change_message_visibility_batch(messages, callback=None)
  clear(*args, **kwargs)
  count(page_size=10, vtimeout=10, callback=None, _attr='ApproximateNumberOfMessages')
  count_slow(*args, **kwargs)
  delete(callback=None)
  delete_message(message, callback=None)
  delete_message_batch(messages, callback=None)
  dump(*args, **kwargs)
  get_attributes(attributes='All', callback=None)
  get_messages(num_messages=1, visibility_timeout=None, attributes=None, wait_time_seconds=None, callback=None)
  get_timeout(callback=None, _attr='VisibilityTimeout')
  load(*args, **kwargs)
  load_from_file(*args, **kwargs)
  load_from_filename(*args, **kwargs)
  load_from_s3(*args, **kwargs)
  read(visibility_timeout=None, wait_time_seconds=None, callback=None)
  remove_permission(label, callback=None)
  save(*args, **kwargs)
  save_to_file(*args, **kwargs)
  save_to_filename(*args, **kwargs)
  save_to_s3(*args, **kwargs)
  set_attribute(attribute, value, callback=None)
  set_timeout(visibility_timeout, callback=None)
  write(message, delay_seconds=None, callback=None)
  write_batch(messages, callback=None)

kombu.asynchronous.aws.sqs.queue.list_first(rs)

  Get the first item in a list, or None if list empty.