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

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.