This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.5.

Azure Service Bus Transport - kombu.transport.azureservicebus

Azure Service Bus Message Queue transport.

The transport can be enabled by setting the CELERY_BROKER_URL to:

` azureservicebus://{SAS policy name}:{SAS key}@{Service Bus Namespace} `

Note that the Shared Access Policy used to connect to Azure Service Bus requires Manage, Send and Listen claims since the broker will create new queues and delete old queues as required.

Note that if the SAS key for the Service Bus account contains a slash, it will have to be regenerated before it can be used in the connection URL.

More information about Azure Service Bus: https://azure.microsoft.com/en-us/services/service-bus/

Transport

class kombu.transport.azureservicebus.Transport(client, **kwargs)

Azure Service Bus transport.

class Channel(*args, **kwargs)

Azure Service Bus channel.

property conninfo

default_peek_lock = False

default_visibility_timeout = 1800

default_wait_time_seconds = 5

domain_format = 'kombu%(vhost)s'

entity_name(name, table={33: 95, 34: 95, 35: 95, 36: 95, 37: 95, 38: 95, 39: 95, 40: 95, 41: 95, 42: 95, 43: 95, 44: 95, 45: 95, 46: 95, 47: 95, 58: 95, 59: 95, 60: 95, 61: 95, 62: 95, 63: 95, 64: 95, 91: 95, 92: 95, 93: 95, 94: 95, 96: 95, 123: 95, 124: 95, 125: 95, 126: 95})

Format AMQP queue name into a valid ServiceBus queue name.

peek_lock

queue_name_prefix

property queue_service

property transport_options

visibility_timeout

wait_time_seconds

default_port = None

polling_interval = 1

Channel

class kombu.transport.azureservicebus.Channel(*args, **kwargs)

Azure Service Bus channel.

property conninfo

default_peek_lock = False

default_visibility_timeout = 1800

default_wait_time_seconds = 5

domain_format = 'kombu%(vhost)s'

entity_name(name, table={33: 95, 34: 95, 35: 95, 36: 95, 37: 95, 38: 95, 39: 95, 40: 95, 41: 95, 42: 95, 43: 95, 44: 95, 45: 95, 46: 95, 47: 95, 58: 95, 59: 95, 60: 95, 61: 95, 62: 95, 63: 95, 64: 95, 91: 95, 92: 95, 93: 95, 94: 95, 96: 95, 123: 95, 124: 95, 125: 95, 126: 95})

Format AMQP queue name into a valid ServiceBus queue name.

peek_lock

queue_name_prefix

property queue_service

property transport_options

visibility_timeout

wait_time_seconds