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.