This document describes the current stable version of Kombu (4.3). For development docs, go here.
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)[source]¶ Azure Service Bus transport.
-
class
Channel
(*args, **kwargs)¶ Azure Service Bus channel.
-
conninfo
¶
-
default_visibility_timeout
= 1800¶
-
domain_format
= u'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.
-
queue_name_prefix
¶
-
queue_service
¶
-
transport_options
¶
-
visibility_timeout
¶
-
-
default_port
= None¶
-
polling_interval
= 1¶
-
class
Channel¶
-
class
kombu.transport.azureservicebus.
Channel
(*args, **kwargs)[source]¶ Azure Service Bus channel.
-
conninfo
¶
-
default_visibility_timeout
= 1800¶
-
domain_format
= u'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})[source]¶ Format AMQP queue name into a valid ServiceBus queue name.
-
queue_service
¶
-
transport_options
¶
-