Управляемое удостоверение в Databricks: DefaultAzureCredential не удалось получить токен из включенных учетных данных. ⇐ Python

[Anonymous]

Я пытаюсь отправить сообщение в служебную шину в Azure. Но я получаю следующую ошибку:

ServiceBusError: Ошибка обработчика: DefaultAzureCredential не удалось
получить токен из включенных учетных данных.

Это строка, которая не работает:
credential = DefaultAzureCredential()
Обычно я бы использовал логин az, но не знаете, как это сделать в блоках данных.
import nest_asyncio
import asyncio
from azure.servicebus import ServiceBusMessage
from azure.servicebus.aio import ServiceBusClient

from azure.identity.aio import DefaultAzureCredential

nest_asyncio.apply()

local_user = dbutils.notebook.entry_point.getDbutils().notebook().getContext().userName().get()

print(local_user)

FULLY_QUALIFIED_NAMESPACE = "xxx.servicebus.windows.net"
TOPIC_NAME = "xxoutbound"

credential = DefaultAzureCredential()
token = credential.get_token('xxx')
print(token)

async def send_single_message(sender):
# Create a Service Bus message and send it to the queue
message = ServiceBusMessage("Single Message")
await sender.send_messages(message)
print("Sent a single message")

async def run():
# create a Service Bus client using the credential
async with ServiceBusClient(
fully_qualified_namespace=FULLY_QUALIFIED_NAMESPACE,
credential=credential,
logging_enable=True) as servicebus_client:
# get a Queue Sender object to send messages to the queue
sender = servicebus_client.get_topic_sender(topic_name=TOPIC_NAME)
async with sender:
# send one message
await send_single_message(sender)

# Close credential when no longer needed.
await credential.close()

print("dfsdf")

asyncio.run(run())
print("Done sending messages")
print("-----------------------")


Подробнее здесь: https://stackoverflow.com/questions/790 ... ieve-a-tok