This document describes the current stable version of Kombu (4.3). For development docs, go here.
Azure Storage Queues Transport - kombu.transport.azurestoragequeues
¶
Azure Storage Queues transport.
The transport can be enabled by setting the CELERY_BROKER_URL to:
`
azurestoragequeues://:{Storage Account Access Key}@{Storage Account Name}
`
Note that if the access key for the storage account contains a slash, it will have to be regenerated before it can be used in the connection URL.
More information about Azure Storage Queues: https://azure.microsoft.com/en-us/services/storage/queues/
Transport¶
-
class
kombu.transport.azurestoragequeues.
Transport
(client, **kwargs)[source]¶ Azure Storage Queues transport.
-
class
Channel
(*args, **kwargs)¶ Azure Storage Queues channel.
-
basic_consume
(queue, no_ack, *args, **kwargs)¶
-
conninfo
¶
-
domain_format
= u'kombu%(vhost)s'¶
-
entity_name
(name, table={33: 45, 34: 45, 35: 45, 36: 45, 37: 45, 38: 45, 39: 45, 40: 45, 41: 45, 42: 45, 43: 45, 44: 45, 45: 45, 46: 45, 47: 45, 58: 45, 59: 45, 60: 45, 61: 45, 62: 45, 63: 45, 64: 45, 91: 45, 92: 45, 93: 45, 94: 45, 95: 45, 96: 45, 123: 45, 124: 45, 125: 45, 126: 45})¶ Format AMQP queue name into a valid Azure Storage Queue name.
-
no_ack
= True¶
-
queue_name_prefix
¶
-
queue_service
¶
-
transport_options
¶
-
-
default_port
= None¶
-
polling_interval
= 1¶
-
class
Channel¶
-
class
kombu.transport.azurestoragequeues.
Channel
(*args, **kwargs)[source]¶ Azure Storage Queues channel.
-
conninfo
¶
-
domain_format
= u'kombu%(vhost)s'¶
-
entity_name
(name, table={33: 45, 34: 45, 35: 45, 36: 45, 37: 45, 38: 45, 39: 45, 40: 45, 41: 45, 42: 45, 43: 45, 44: 45, 45: 45, 46: 45, 47: 45, 58: 45, 59: 45, 60: 45, 61: 45, 62: 45, 63: 45, 64: 45, 91: 45, 92: 45, 93: 45, 94: 45, 95: 45, 96: 45, 123: 45, 124: 45, 125: 45, 126: 45})[source]¶ Format AMQP queue name into a valid Azure Storage Queue name.
-
no_ack
= True¶
-
queue_service
¶
-
transport_options
¶
-