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

Question

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

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

有什么建议吗

Answer 1

我知道您正在寻找从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()