azure-servicebus-py

name	azure-servicebus-py
description	Azure Service Bus SDK for Python messaging. Use for queues, topics, subscriptions, and enterprise messaging patterns.
type	skill
created	2026-02-27T00:00:00.000Z
domain	cloud-infrastructure
category	azure
risk	unknown
source	community
tags	["skill","cloud-infrastructure","azure","servicebus"]

Azure Service Bus SDK for Python

Enterprise messaging for reliable cloud communication with queues and pub/sub topics.

Installation

pip install azure-servicebus azure-identity

Environment Variables

SERVICEBUS_FULLY_QUALIFIED_NAMESPACE=<namespace>.servicebus.windows.net
SERVICEBUS_QUEUE_NAME=myqueue
SERVICEBUS_TOPIC_NAME=mytopic
SERVICEBUS_SUBSCRIPTION_NAME=mysubscription

Authentication

from azure.identity import DefaultAzureCredential
from azure.servicebus import ServiceBusClient

credential = DefaultAzureCredential()
namespace = "<namespace>.servicebus.windows.net"

client = ServiceBusClient(
    fully_qualified_namespace=namespace,
    credential=credential
)

Client Types

Client	Purpose	Get From
ServiceBusClient	Connection management	Direct instantiation
ServiceBusSender	Send messages	client.get_queue_sender() / get_topic_sender()
ServiceBusReceiver	Receive messages	client.get_queue_receiver() / get_subscription_receiver()

Send Messages (Async)

import asyncio
from azure.servicebus.aio import ServiceBusClient
from azure.servicebus import ServiceBusMessage
from azure.identity.aio import DefaultAzureCredential

async def send_messages():
    credential = DefaultAzureCredential()
    
    async with ServiceBusClient(
        fully_qualified_namespace="<namespace>.servicebus.windows.net",
        credential=credential
    )  client:
        sender = client.get_queue_sender(queue_name=)
        
          sender:
            
            message = ServiceBusMessage()
             sender.send_messages(message)
            
            
            messages = [ServiceBusMessage()  i  ()]
             sender.send_messages(messages)
            
            
            batch =  sender.create_message_batch()
             i  ():
                :
                    batch.add_message(ServiceBusMessage())
                 ValueError:  
                     sender.send_messages(batch)
                    batch =  sender.create_message_batch()
                    batch.add_message(ServiceBusMessage())
             sender.send_messages(batch)

asyncio.run(send_messages())