python-3.x - 如何使用 Python 从 Azure 服务总线主题中读取所有消息？

Question

我想使用 python 从 azure 服务总线读取所有消息。目前它只获取一条消息。

from azure.servicebus.control_client import ServiceBusService, Message, Topic, Rule, DEFAULT_RULE_NAME

    bus_service = ServiceBusService(
        service_namespace='<NameSpace>',
        shared_access_key_name='<KeyName>',
        shared_access_key_value='<ConnectionString>')

msg = bus_service.receive_subscription_message('topic', 'msglist', peek_lock=True)
print(msg.body)

如何使用 python 3 从主题中批量获取所有消息

Answer 1

这可以通过使用Receiver支持批处理操作的对象来实现。请参阅此示例，该示例展示了如何获取此对象以进行订阅。

为了保证您获得批量消息，您必须将prefetch参数get_receiver()设置为批量大小，因此max_batch_size参数设置fetch_next()为相同。