azure.servicebus.aio.management package¶

class azure.servicebus.aio.management.ServiceBusAdministrationClient(fully_qualified_namespace: str, credential: AsyncTokenCredential, **kwargs)[source]¶

Use this client to create, update, list, and delete resources of a ServiceBus namespace.

Parameters

fully_qualified_namespace (str) – The fully qualified host name for the Service Bus namespace.
credential (AsyncTokenCredential) – To authenticate to manage the entities of the ServiceBus namespace.

async close() → None [source]¶

async create_queue(name: str, **kwargs) → azure.servicebus.management._models.QueueProperties[source]¶

Create a queue.

Parameters

name (str) – Name of the queue.

Keyword Arguments

authorization_rules – Authorization rules for resource.
auto_delete_on_idle – ISO 8601 timeSpan idle interval after which the queue is automatically deleted. The minimum duration is 5 minutes.
dead_lettering_on_message_expiration – A value that indicates whether this queue has dead letter support when a message expires.
default_message_time_to_live – ISO 8601 default message timespan to live value. This is the duration after which the message expires, starting from when the message is sent to Service Bus. This is the default value used when TimeToLive is not set on a message itself.
duplicate_detection_history_time_window – ISO 8601 timeSpan structure that defines the duration of the duplicate detection history. The default value is 10 minutes.
enable_batched_operations – Value that indicates whether server-side batched operations are enabled.
enable_express – A value that indicates whether Express Entities are enabled. An express queue holds a message in memory temporarily before writing it to persistent storage.
enable_partitioning – A value that indicates whether the queue is to be partitioned across multiple message brokers.
lock_duration – ISO 8601 timespan duration of a peek-lock; that is, the amount of time that the message is locked for other receivers. The maximum value for LockDuration is 5 minutes; the default value is 1 minute.
max_delivery_count – The maximum delivery count. A message is automatically deadlettered after this number of deliveries. Default value is 10.
max_size_in_megabytes – The maximum size of the queue in megabytes, which is the size of memory allocated for the queue.
requires_duplicate_detection – A value indicating if this queue requires duplicate detection.
requires_session – A value that indicates whether the queue supports the concept of sessions.
forward_to – The name of the recipient entity to which all the messages sent to the queue are forwarded to.
user_metadata – Custom metdata that user can associate with the description. Max length is 1024 chars.
forward_dead_lettered_messages_to – The name of the recipient entity to which all the dead-lettered messages of this subscription are forwarded to.

Return type

QueueProperties

async create_rule(topic_name: str, subscription_name: str, name: str, **kwargs) → azure.servicebus.management._models.RuleProperties[source]¶

Create a rule for a topic subscription.

Parameters

topic_name (str) – The topic that will own the to-be-created subscription rule.
subscription_name (str) – The subscription that will own the to-be-created rule.
name (str) – Name of the rule.

Keyword Arguments

filter – The filter of the rule.
action – The action of the rule.

Return type

RuleProperties

async create_subscription(topic_name: str, name: str, **kwargs) → azure.servicebus.management._models.SubscriptionProperties[source]¶

Create a topic subscription.

Parameters

topic_name (str) – The topic that will own the to-be-created subscription.
name (str) – Name of the subscription.

Keyword Arguments

lock_duration – ISO 8601 timespan duration of a peek-lock; that is, the amount of time that the message is locked for other receivers. The maximum value for LockDuration is 5 minutes; the default value is 1 minute.
requires_session – A value that indicates whether the queue supports the concept of sessions.
default_message_time_to_live – ISO 8601 default message timespan to live value. This is the duration after which the message expires, starting from when the message is sent to Service Bus. This is the default value used when TimeToLive is not set on a message itself.
dead_lettering_on_message_expiration – A value that indicates whether this subscription has dead letter support when a message expires.
dead_lettering_on_filter_evaluation_exceptions – A value that indicates whether this subscription has dead letter support when a message expires.
max_delivery_count – The maximum delivery count. A message is automatically deadlettered after this number of deliveries. Default value is 10.
enable_batched_operations – Value that indicates whether server-side batched operations are enabled.
forward_to – The name of the recipient entity to which all the messages sent to the subscription are forwarded to.
user_metadata – Metadata associated with the subscription. Maximum number of characters is 1024.
forward_dead_lettered_messages_to – The name of the recipient entity to which all the messages sent to the subscription are forwarded to.
auto_delete_on_idle – ISO 8601 timeSpan idle interval after which the subscription is automatically deleted. The minimum duration is 5 minutes.

Return type

SubscriptionProperties

async create_topic(name: str, **kwargs) → azure.servicebus.management._models.TopicProperties[source]¶

Create a topic.

Parameters

name (str) – Name of the topic.

Keyword Arguments

default_message_time_to_live – ISO 8601 default message timespan to live value. This is the duration after which the message expires, starting from when the message is sent to Service Bus. This is the default value used when TimeToLive is not set on a message itself.
max_size_in_megabytes – The maximum size of the topic in megabytes, which is the size of memory allocated for the topic.
requires_duplicate_detection – A value indicating if this topic requires duplicate detection.
duplicate_detection_history_time_window – ISO 8601 timeSpan structure that defines the duration of the duplicate detection history. The default value is 10 minutes.
enable_batched_operations – Value that indicates whether server-side batched operations are enabled.
size_in_bytes – The size of the topic, in bytes.
filtering_messages_before_publishing – Filter messages before publishing.
authorization_rules – Authorization rules for resource.
support_ordering – A value that indicates whether the topic supports ordering.
auto_delete_on_idle – ISO 8601 timeSpan idle interval after which the topic is automatically deleted. The minimum duration is 5 minutes.
enable_partitioning – A value that indicates whether the topic is to be partitioned across multiple message brokers.
enable_express – A value that indicates whether Express Entities are enabled. An express queue holds a message in memory temporarily before writing it to persistent storage.
user_metadata – Metadata associated with the topic.

Return type

TopicProperties

async delete_queue(queue_name: str, **kwargs) → None [source]¶

Delete a queue.

Parameters: queue_name (str) – The name of the queue or a QueueProperties with name.
Return type: None

async delete_rule(topic_name: str, subscription_name: str, rule_name: str, **kwargs) → None [source]¶

Delete a topic subscription rule.

Parameters

topic_name (str) – The topic that owns the subscription.
subscription_name (str) – The subscription that owns the topic.
rule_name (str) – The to-be-deleted rule.

Return type

None

async delete_subscription(topic_name: str, subscription_name: str, **kwargs) → None [source]¶

Delete a topic subscription.

Parameters

topic_name (str) – The topic that owns the subscription.
subscription_name (str) – The subscription to be deleted.

Return type

None

async delete_topic(topic_name: str, **kwargs) → None [source]¶

Delete a topic.

Parameters: topic_name (str) – The topic to be deleted.
Return type: None

classmethod from_connection_string(conn_str: str, **kwargs: Any) → azure.servicebus.aio.management._management_client_async.ServiceBusAdministrationClient[source]¶

Create a client from connection string.

Parameters: conn_str (str) – The connection string of the Service Bus Namespace.
Return type: ServiceBusAdministrationClient

async get_namespace_properties(**kwargs) → azure.servicebus.management._models.NamespaceProperties[source]¶

Get the namespace properties

Return type: NamespaceProperties

async get_queue(queue_name: str, **kwargs) → azure.servicebus.management._models.QueueProperties[source]¶

Get the properties of a queue.

Parameters: queue_name (str) – The name of the queue.
Return type: QueueProperties

async get_queue_runtime_properties(queue_name: str, **kwargs) → azure.servicebus.management._models.QueueRuntimeProperties[source]¶

Get the runtime information of a queue.

Parameters: queue_name (str) – The name of the queue.
Return type: QueueRuntimeProperties

async get_rule(topic_name: str, subscription_name: str, rule_name: str, **kwargs) → azure.servicebus.management._models.RuleProperties[source]¶

Get the properties of a topic subscription rule.

Parameters

topic_name (str) – The topic that owns the subscription.
subscription_name (str) – The subscription that owns the rule.
rule_name (str) – Name of the rule.

Return type

RuleProperties

async get_subscription(topic_name: str, subscription_name: str, **kwargs) → azure.servicebus.management._models.SubscriptionProperties[source]¶

Get the properties of a topic subscription.

Parameters

topic_name (str) – The topic that owns the subscription.
subscription_name (str) – name of the subscription.

Return type

SubscriptionProperties

async get_subscription_runtime_properties(topic_name: str, subscription_name: str, **kwargs) → azure.servicebus.management._models.SubscriptionRuntimeProperties[source]¶

Get a topic subscription runtime info.

Parameters

topic_name (str) – The topic that owns the subscription.
subscription_name (str) – name of the subscription.

Return type

SubscriptionRuntimeProperties

async get_topic(topic_name: str, **kwargs) → azure.servicebus.management._models.TopicProperties[source]¶

Get the properties of a topic.

Parameters: topic_name (str) – The name of the topic.
Return type: TopicDescription

async get_topic_runtime_properties(topic_name: str, **kwargs) → azure.servicebus.management._models.TopicRuntimeProperties[source]¶

Get the runtime information of a topic.

Parameters: topic_name (str) – The name of the topic.
Return type: TopicRuntimeProperties

list_queues(**kwargs: Any) → azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.QueueProperties][source]¶

List the queues of a ServiceBus namespace.

Returns: An iterable (auto-paging) response of QueueProperties.
Return type: AsyncItemPaged[QueueProperties]

list_queues_runtime_properties(**kwargs: Any) → azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.QueueRuntimeProperties][source]¶

List the runtime information of the queues in a ServiceBus namespace.

Returns: An iterable (auto-paging) response of QueueRuntimeProperties.
Return type: AsyncItemPaged[QueueRuntimeProperties]

list_rules(topic_name: str, subscription_name: str, **kwargs: Any) → azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.RuleProperties][source]¶

List the rules of a topic subscription.

Parameters

topic_name (str) – The topic that owns the subscription.
subscription_name (str) – The subscription that owns the rules.

Returns

An iterable (auto-paging) response of RuleProperties.

Return type

AsyncItemPaged[RuleProperties]

list_subscriptions(topic_name: str, **kwargs: Any) → azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.SubscriptionProperties][source]¶

List the subscriptions of a ServiceBus Topic.

Parameters: topic_name (str) – The topic that owns the subscription.
Returns: An iterable (auto-paging) response of SubscriptionProperties.
Return type: AsyncItemPaged[SubscriptionProperties]

list_subscriptions_runtime_properties(topic_name: str, **kwargs: Any) → azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.SubscriptionRuntimeProperties][source]¶

List the subscriptions runtime information of a ServiceBus.

Parameters: topic_name (str) – The topic that owns the subscription.
Returns: An iterable (auto-paging) response of SubscriptionRuntimeProperties.
Return type: AsyncItemPaged[SubscriptionRuntimeProperties]

list_topics(**kwargs: Any) → azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.TopicProperties][source]¶

List the topics of a ServiceBus namespace.

Returns: An iterable (auto-paging) response of TopicProperties.
Return type: AsyncItemPaged[TopicProperties]

list_topics_runtime_properties(**kwargs: Any) → azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.TopicRuntimeProperties][source]¶

List the topics runtime information of a ServiceBus namespace.

Returns: An iterable (auto-paging) response of TopicRuntimeProperties.
Return type: AsyncItemPaged[TopicRuntimeProperties]

async update_queue(queue: azure.servicebus.management._models.QueueProperties, **kwargs) → None [source]¶

Update a queue.

Before calling this method, you should use get_queue, create_queue or list_queues to get a QueueProperties instance, then update the properties. Only a portion of properties can be updated. Refer to https://docs.microsoft.com/en-us/rest/api/servicebus/update-queue.

Parameters: queue (QueueProperties) – The queue that is returned from get_queue, create_queue or list_queues and has the updated properties.
Return type: None

async update_rule(topic_name: str, subscription_name: str, rule: azure.servicebus.management._models.RuleProperties, **kwargs) → None [source]¶

Update a rule.

Before calling this method, you should use get_rule, create_rule or list_rules to get a RuleProperties instance, then update the properties.

Parameters

topic_name (str) – The topic that owns the subscription.
subscription_name (str) – The subscription that owns this rule.
rule (RuleProperties) – The rule that is returned from get_rule,

create_rule, or list_rules and has the updated properties. :rtype: None

async update_subscription(topic_name: str, subscription: azure.servicebus.management._models.SubscriptionProperties, **kwargs) → None [source]¶

Update a subscription.

Before calling this method, you should use get_subscription, update_subscription or list_subscription to get a SubscriptionProperties instance, then update the properties.

Parameters

topic_name (str) – The topic that owns the subscription.
subscription (SubscriptionProperties) – The subscription that is returned from get_subscription, update_subscription or list_subscription and has the updated properties.

Return type

None

async update_topic(topic: azure.servicebus.management._models.TopicProperties, **kwargs) → None [source]¶

Update a topic.

Before calling this method, you should use get_topic, create_topic or list_topics to get a TopicProperties instance, then update the properties. Only a portion of properties can be updated. Refer to https://docs.microsoft.com/en-us/rest/api/servicebus/update-topic.

Parameters: topic (TopicProperties) – The topic that is returned from get_topic, create_topic, or list_topics and has the updated properties.
Return type: None