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()
SQS在boto3没有服务员。在
我知道您正在寻找从Python代码监听SQS队列的高级方法:
multi_sqs_listener可能有助于您实现这一点(披露:我是作者):
相关问题 更多 >
编程相关推荐