关于如何在awssq上使用waiter函数的Python示例

2024-09-30 16:19:55 发布

您现在位置:Python中文网/ 问答频道 /正文

我尝试使用AWS上SQS可用的waiter功能。但是,我没有看到任何文档和python示例

awsboto/SQS文档链接在这里引用Waiter:http://boto3.readthedocs.io/en/latest/guide/clients.html#waiters,但没有给出使用SQS的任何详细示例

有什么建议吗


Tags: 文档io功能awshttp示例链接readthedocs
2条回答

SQS在boto3没有服务员。在

Note if a client does not have any waiters, it will return an empty list when accessing its waiter_names attribute.

import boto3
sqs = boto3.client('sqs')
sqs.waiter_names
[]

我知道您正在寻找从Python代码监听SQS队列的高级方法:

multi_sqs_listener可能有助于您实现这一点(披露:我是作者):

from multi_sqs_listener import QueueConfig, EventBus, MultiSQSListener

class MyListener(MultiSQSListener):
    def handle_message(self, queue, bus, priority, message):
        # This is where your actual event handler code will sit
        print(message.body)

my_event_bus = EventBus()
EventBus.register_buses([my_event_bus])

my_queue = QueueConfig('my-queue', my_event_bus)
my_listener = MyListener([my_queue])
my_listener.listen()

相关问题 更多 >