How to connect to azure service bus and send messages from azure databricks

Question

we wanted to send messages to azure service bus from azure databricks. Are there any ways ?

Answer 1

I found this thread already https://learn.microsoft.com/en-us/answers/questions/723406/copy-azure-service-bus-messages-in-queue-to-data-l, so I will help you with some code in Python.

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

# Replace with your connection string
connection_str = "YOUR_SERVICE_BUS_CONNECTION_STRING"
queue_name = "YOUR_QUEUE_NAME"

# Create a Service Bus client
with ServiceBusClient.from_connection_string(connection_str) as client:

    # Send messages to the queue
    with client.get_queue_sender(queue_name) as sender:
        msg = ServiceBusMessage("Hello, Azure Service Bus!")
        sender.send_messages(msg)
        print("Message sent!")

Answer 2

Hi Mahesh,

You should use import requests and send REST API requests to Azure Service Bus:

Azure Service Bus REST API

https://learn.microsoft.com/en-us/rest/api/servicebus/

Python Requests: How to Send POST Requests

https://scrapeops.io/python-web-scraping-playbook/python-requests-post-requests/

Send Message

https://learn.microsoft.com/en-us/rest/api/servicebus/send-message-to-queue

---

If this is helpful please accept answer.