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

Azure Storage Queues Transport - kombu.transport.azurestoragequeues

Azure Storage Queues transport module for kombu.

More information about Azure Storage Queues: https://azure.microsoft.com/en-us/services/storage/queues/

Features

  • Type: Virtual

  • Supports Direct: Unreviewed

  • Supports Topic: Unreviewed

  • Supports Fanout: Unreviewed

  • Supports Priority: Unreviewed

  • Supports TTL: Unreviewed

Connection String

Connection string has the following format:

azurestoragequeues://STORAGE_ACCOUNT_ACCESS_KEY@STORAGE_ACCOUNT_URL
azurestoragequeues://SAS_TOKEN@STORAGE_ACCOUNT_URL

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.

Transport Options

  • queue_name_prefix

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)

Consume from queue.

property conninfo
domain_format = '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
property queue_service
property transport_options
classmethod as_uri(uri: str, include_password=False, mask='**') str[source]

Customise the display format of the URI.

can_parse_url = True

Set to True if Connection should pass the URL unmodified.

default_port = None

port number used when no port is specified.

static parse_uri(uri: str) tuple[str, str][source]
polling_interval = 1

Time to sleep between unsuccessful polls.

Channel

class kombu.transport.azurestoragequeues.Channel(*args, **kwargs)[source]

Azure Storage Queues channel.

basic_consume(queue, no_ack, *args, **kwargs)[source]

Consume from queue.

property conninfo
domain_format = '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_name_prefix
property queue_service
property transport_options