如何使用Python读取Azure服务总线主题中的所有消息？
我想使用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)
共有1个答案
这可以通过使用支持批处理操作的receiver对象来实现。请参阅此示例，该示例展示了如何为订阅获取此对象。
为了保证获得批消息，必须将get_receiver()的prefetch参数设置为您的批大小，然后将fetch_next()的max_batch_size参数设置为相同的批大小。
-
我想从azure服务总线（队列）读取所有消息。 我已经按照下面的指示链接https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-php-how-to-use-queues 目前它只能获取一条消息。。 我想从服务总线（队列）获取所有消息。 提前谢谢。。
-
我是Azure服务总线的新手，我应该将消息推送到队列中，然后有一个单独的计划任务，该任务将读取该队列中的所有活动消息，并将它们批量导入到sql我以前尝试过这个代码，当我调用时它正在工作它在发送消息后立即工作，但现在它在单独的计划任务中不工作。任何帮助为什么或什么我可以用来批量阅读信息或这是不可能的
-
参考https://github.com/Azure/azure-service-bus/tree/master/samples/dotnet/gettingstart/microsoft.Azure.servicebus/basicsendreceiveusingtopicsubscriptionclient，我了解Azure服务总线主题的一般工作方式，我的问题更多地是关于它实际上是如何工作的。
-
我正在使用Azure服务总线队列。但是我不能使用“获取所有队列消息（peek Lock）：微软内置于api”从队列中获取所有消息。 有没有办法获取所有队列消息？ {"$连接"：{"值"：{"servicebus_1"：{"连接ID"："/订阅/c776fex3-6aec-4722-b099-b054c267b240/资源组/Plugin-Resources/提供者/Microsoft.网络/连接/