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

SQS队列- kombu.asynchronous.aws.sqs.queue

Amazon SQS队列实施。

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

异步SQS队列。

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)

获取列表中的第一项，如果列表为空，则为None。