1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
#!/usr/bin/env python
# --------------------------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.
# --------------------------------------------------------------------------------------------
"""
Example to show connection-string based authentication of the ServiceBusClient.
Note: To get credentials, one can either obtain the connection string from the Azure Portal,
or use the Azure CLI snippet below to populate an environment variable with the service bus connection string. The following is in bash:
```bash
RES_GROUP=<resource-group-name>
NAMESPACE_NAME=<servicebus-namespace-name>
export SERVICE_BUS_CONN_STR=$(az servicebus namespace authorization-rule keys list --resource-group $RES_GROUP --namespace-name $NAMESPACE_NAME --name RootManageSharedAccessKey --query primaryConnectionString --output tsv)
```
"""
# pylint: disable=C0111
from azure.servicebus.aio import ServiceBusClient
import os
import asyncio
connstr = os.environ['SERVICE_BUS_CONNECTION_STR']
async def run():
async with ServiceBusClient.from_connection_string(connstr) as client:
pass # Client is now initialized and can be used.
loop = asyncio.get_event_loop()
loop.run_until_complete(run())
|
