Установите соединение между Databricks и очередью служебной шины Azure для отправки сообщений. ⇐ Python

[Anonymous]

Мне нужно подключиться к служебной шине Azure из Databricks (pyspark), чтобы отправлять сообщения json в существующую очередь
с использованием принципа службы или через AAD в качестве аутентификации.
Я попробовал приведенный ниже код:

Код: Выделить всё

from azure.identity import ClientSecretCredential
from azure.servicebus import ServiceBusClient, ServiceBusMessage

#AAD and service Bus Details

tenant_id="my-tenanted"
client_id = "my-ClientID"
client_secret= "my client secret"

namespace="Azure Service Bus Hostname"
queue_name ="myqueue"

#Create Credential

credential=ClientSecretCredential(
tenant_id=tenant_id
client_id = client_id
client_secret= client_secret
)

# Create a Service Bus client

servicebus_client= ServiceBusClient
(   fully_qualified_namespace=f"{namespace}.servicebus.windows.net"
credential=credential
)

#Send a sample message

with servicebus_client:
sender = servicebus_client.get_queue_sender(queue_name=queue_name)
with sender:
message=ServiceBusMessage("Hello,from Databricks")
sender.send_messages(message)
print("Message Sent")

Я получаю сообщение об ошибке типа: «ServiceBusAuthenticationError»: в служебной шине произошла ошибка. Условие ошибки: amqp:client_error

Подробнее здесь: https://stackoverflow.com/questions/788 ... to-send-me