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

Async SQS Queue.

add_permission(label, aws_account_id, action_name, callback=None)[source]
change_message_visibility_batch(messages, callback=None)[source]
clear(*args, **kwargs)
count(page_size=10, vtimeout=10, callback=None, _attr='ApproximateNumberOfMessages')[source]
count_slow(*args, **kwargs)
delete(callback=None)[source]
delete_message(message, callback=None)[source]
delete_message_batch(messages, callback=None)[source]
dump(*args, **kwargs)
get_attributes(attributes='All', callback=None)[source]
get_messages(num_messages=1, visibility_timeout=None, attributes=None, wait_time_seconds=None, callback=None)[source]
get_timeout(callback=None, _attr='VisibilityTimeout')[source]
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)[source]
remove_permission(label, callback=None)[source]
save(*args, **kwargs)
save_to_file(*args, **kwargs)
save_to_filename(*args, **kwargs)
save_to_s3(*args, **kwargs)
set_attribute(attribute, value, callback=None)[source]
set_timeout(visibility_timeout, callback=None)[source]
write(message, delay_seconds=None, callback=None)[source]
write_batch(messages, callback=None)[source]
kombu.asynchronous.aws.sqs.queue.list_first(rs)[source]

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