如何使用Python从Azure Service Bus主题读取所有消息?
问题描述：
我想使用python从azure服务总线中读取所有消息.目前，它仅提取一条消息.
I want to read all messages from azure service bus using python. Currently it fetch only one message.
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从主题中批量获取所有消息
How can I get all the message in bulk from the topic with python 3
答
这可以通过使用此样本，其中展示了如何获取该对象进行订阅.
This is possible by using a Receiver object which supports batch operations. Refer this sample which showcases how to get this object for a subscription.
要确保收到大量消息，必须设置 max_batch_size自变量fetch_next() 相同.
To guarantee you get batches of messages, you have to set the prefetch argument of get_receiver() to your batch size and consequently the max_batch_size argument of fetch_next() to the same.