File tree Expand file tree Collapse file tree 1 file changed +6
-10
lines changed
sdk/servicebus/azure-servicebus Expand file tree Collapse file tree 1 file changed +6
-10
lines changed Original file line number Diff line number Diff line change @@ -211,24 +211,20 @@ from azure.identity.aio import DefaultAzureCredential
211211from azure.servicebus import ServiceBusMessage
212212from azure.servicebus.aio import ServiceBusClient
213213
214- FULLY_QUALIFIED_NAMESPACE = " your-namespace .servicebus.windows.net"
215- QUEUE_NAME = " your- queue"
214+ FULLY_QUALIFIED_NAMESPACE = " .servicebus.windows.net"
215+ QUEUE_NAME = " < queue name> "
216216
217217lock = asyncio.Lock()
218218
219- async def send_messages_async (client , queue_name ):
220- """ Send messages using async API with locks"""
219+ async def send_messages (client ):
221220 async with lock:
222- async with client.get_queue_sender(queue_name) as sender:
223- messages = [ServiceBusMessage(f " Hello { i} " ) for i in range (10 )]
224- await sender.send_messages(messages)
221+ async with client.get_queue_sender(QUEUE_NAME ) as sender:
222+ await asyncio.gather(* (sender.send_messages(ServiceBusMessage(" hello" )) for _ in range (10 )))
225223
226224async def main ():
227225 credential = DefaultAzureCredential()
228226 async with ServiceBusClient(FULLY_QUALIFIED_NAMESPACE , credential) as client:
229- # Use asyncio.gather for concurrent execution
230- tasks = [send_messages_async(client, QUEUE_NAME ) for _ in range (3 )]
231- await asyncio.gather(* tasks)
227+ await send_messages(client)
232228
233229if __name__ == " __main__" :
234230 asyncio.run(main())
You can’t perform that action at this time.
0 commit comments