ServiceBusAdministrationClient Class

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

Inheritance

builtins.object

ServiceBusAdministrationClient

Constructor

ServiceBusAdministrationClient(fully_qualified_namespace: str, credential: AsyncTokenCredential, **kwargs: Any)

Parameters

fully_qualified_namespace

str

Required

The fully qualified host name for the Service Bus namespace.

credential

<xref:AsyncTokenCredential>

Required

To authenticate to manage the entities of the ServiceBus namespace.

api_version

str

The Service Bus API version to use for requests. Default value is the most recent service version that is compatible with the current SDK. Setting to an older version may result in reduced feature compatibility.

Methods

close
create_queue	Create a queue.
create_rule	Create a rule for a topic subscription.
create_subscription	Create a topic subscription.
create_topic	Create a topic.
delete_queue	Delete a queue.
delete_rule	Delete a topic subscription rule.
delete_subscription	Delete a topic subscription.
delete_topic	Delete a topic.
from_connection_string	Create a client from connection string.
get_namespace_properties	Get the namespace properties
get_queue	Get the properties of a queue.
get_queue_runtime_properties	Get the runtime information of a queue.
get_rule	Get the properties of a topic subscription rule.
get_subscription	Get the properties of a topic subscription.
get_subscription_runtime_properties	Get a topic subscription runtime info.
get_topic	Get the properties of a topic.
get_topic_runtime_properties	Get the runtime information of a topic.
list_queues	List the queues of a ServiceBus namespace.
list_queues_runtime_properties	List the runtime information of the queues in a ServiceBus namespace.
list_rules	List the rules of a topic subscription.
list_subscriptions	List the subscriptions of a ServiceBus Topic.
list_subscriptions_runtime_properties	List the subscriptions runtime information of a ServiceBus.
list_topics	List the topics of a ServiceBus namespace.
list_topics_runtime_properties	List the topics runtime information of a ServiceBus namespace.
update_queue	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. You could also pass keyword arguments for updating properties in the form of <property_name>=<property_value> which will override whatever was specified in the QueueProperties instance. Refer to ~azure.servicebus.management.QueueProperties for names of properties.
update_rule	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. You could also pass keyword arguments for updating properties in the form of <property_name>=<property_value> which will override whatever was specified in the RuleProperties instance. Refer to ~azure.servicebus.management.RuleProperties for names of properties.
update_subscription	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. You could also pass keyword arguments for updating properties in the form of <property_name>=<property_value> which will override whatever was specified in the SubscriptionProperties instance. Refer to ~azure.servicebus.management.SubscriptionProperties for names of properties.
update_topic	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. You could also pass keyword arguments for updating properties in the form of <property_name>=<property_value> which will override whatever was specified in the TopicProperties instance. Refer to ~azure.servicebus.management.TopicProperties for names of properties.

close

async close() -> None

create_queue

Create a queue.

async create_queue(queue_name: str, **kwargs) -> azure.servicebus.management._models.QueueProperties

Parameters

queue_name

str

Required

Name of the queue.

authorization_rules

list[AuthorizationRule]

Authorization rules for resource.

auto_delete_on_idle

<xref:Union>[timedelta, str]

ISO 8601 timeSpan idle interval after which the queue is automatically deleted. The minimum duration is 5 minutes. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

dead_lettering_on_message_expiration

bool

A value that indicates whether this queue has dead letter support when a message expires.

default_message_time_to_live

<xref:Union>[timedelta, str]

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. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

duplicate_detection_history_time_window

<xref:Union>[timedelta, str]

ISO 8601 timeSpan structure that defines the duration of the duplicate detection history. The default value is 10 minutes. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

enable_batched_operations

bool

Value that indicates whether server-side batched operations are enabled.

enable_express

bool

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

bool

A value that indicates whether the queue is to be partitioned across multiple message brokers.

lock_duration

<xref:Union>[timedelta, str]

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. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

max_delivery_count

int

The maximum delivery count. A message is automatically deadlettered after this number of deliveries. Default value is 10.

max_size_in_megabytes

int

The maximum size of the queue in megabytes, which is the size of memory allocated for the queue.

requires_duplicate_detection

bool

A value indicating if this queue requires duplicate detection.

requires_session

bool

A value that indicates whether the queue supports the concept of sessions.

forward_to

str

The name of the recipient entity to which all the messages sent to the queue are forwarded to.

user_metadata

str

Custom metdata that user can associate with the description. Max length is 1024 chars.

forward_dead_lettered_messages_to

str

The name of the recipient entity to which all the dead-lettered messages of this subscription are forwarded to.

max_message_size_in_kilobytes

int

The maximum size in kilobytes of message payload that can be accepted by the queue. This feature is only available when using a Premium namespace and Service Bus API version "2021-05" or higher. The minimum allowed value is 1024 while the maximum allowed value is 102400. Default value is 1024.

Return type

QueueProperties

create_rule

Create a rule for a topic subscription.

async create_rule(topic_name: str, subscription_name: str, rule_name: str, **kwargs) -> azure.servicebus.management._models.RuleProperties

Parameters

topic_name

str

Required

The topic that will own the to-be-created subscription rule.

subscription_name

str

Required

The subscription that will own the to-be-created rule.

rule_name

str

Required

Name of the rule.

filter

<xref:Union>[<xref:azure.servicebus.management.CorrelationRuleFilter,azure.servicebus.management.SqlRuleFilter>]

The filter of the rule. The default value is ~azure.servicebus.management.TrueRuleFilter

action

<xref:Optional>[SqlRuleAction]

The action of the rule.

Return type

RuleProperties

create_subscription

Create a topic subscription.

async create_subscription(topic_name: str, subscription_name: str, **kwargs) -> azure.servicebus.management._models.SubscriptionProperties

Parameters

topic_name

str

Required

The topic that will own the to-be-created subscription.

subscription_name

str

Required

Name of the subscription.

lock_duration

<xref:Union>[timedelta, str]

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. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

requires_session

bool

A value that indicates whether the queue supports the concept of sessions.

default_message_time_to_live

<xref:Union>[timedelta, str]

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. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

dead_lettering_on_message_expiration

bool

A value that indicates whether this subscription has dead letter support when a message expires.

dead_lettering_on_filter_evaluation_exceptions

bool

A value that indicates whether this subscription has dead letter support when a message expires.

max_delivery_count

int

The maximum delivery count. A message is automatically deadlettered after this number of deliveries. Default value is 10.

enable_batched_operations

bool

Value that indicates whether server-side batched operations are enabled.

forward_to

str

The name of the recipient entity to which all the messages sent to the subscription are forwarded to.

user_metadata

str

Metadata associated with the subscription. Maximum number of characters is 1024.

forward_dead_lettered_messages_to

str

The name of the recipient entity to which all the messages sent to the subscription are forwarded to.

auto_delete_on_idle

<xref:Union>[timedelta, str]

ISO 8601 timeSpan idle interval after which the subscription is automatically deleted. The minimum duration is 5 minutes. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

Return type

SubscriptionProperties

create_topic

Create a topic.

async create_topic(topic_name: str, **kwargs) -> azure.servicebus.management._models.TopicProperties

Parameters

topic_name

str

Required

Name of the topic.

default_message_time_to_live

<xref:Union>[timedelta, str]

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. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

max_size_in_megabytes

<xref:long>

The maximum size of the topic in megabytes, which is the size of memory allocated for the topic.

requires_duplicate_detection

bool

A value indicating if this topic requires duplicate detection.

duplicate_detection_history_time_window

<xref:Union>[timedelta, str]

ISO 8601 timeSpan structure that defines the duration of the duplicate detection history. The default value is 10 minutes. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

enable_batched_operations

bool

Value that indicates whether server-side batched operations are enabled.

size_in_bytes

int

The size of the topic, in bytes.

filtering_messages_before_publishing

bool

Filter messages before publishing.

authorization_rules

list[AuthorizationRule]

Authorization rules for resource.

support_ordering

bool

A value that indicates whether the topic supports ordering.

auto_delete_on_idle

<xref:Union>[timedelta, str]

ISO 8601 timeSpan idle interval after which the topic is automatically deleted. The minimum duration is 5 minutes. Input value of either type ~datetime.timedelta or string in ISO 8601 duration format like "PT300S" is accepted.

enable_partitioning

bool

A value that indicates whether the topic is to be partitioned across multiple message brokers.

enable_express

bool

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

str

Metadata associated with the topic.

max_message_size_in_kilobytes

int

The maximum size in kilobytes of message payload that can be accepted by the queue. This feature is only available when using a Premium namespace and Service Bus API version "2021-05" or higher. The minimum allowed value is 1024 while the maximum allowed value is 102400. Default value is 1024.

Return type

TopicProperties

delete_queue

Delete a queue.

async delete_queue(queue_name: str, **kwargs) -> None

Parameters

queue_name

str

Required

The name of the queue or a QueueProperties with name.

Return type

None

delete_rule

Delete a topic subscription rule.

async delete_rule(topic_name: str, subscription_name: str, rule_name: str, **kwargs) -> None

Parameters

topic_name

str

Required

The topic that owns the subscription.

subscription_name

str

Required

The subscription that owns the topic.

rule_name

str

Required

The to-be-deleted rule.

Return type

None

delete_subscription

Delete a topic subscription.

async delete_subscription(topic_name: str, subscription_name: str, **kwargs) -> None

Parameters

topic_name

str

Required

The topic that owns the subscription.

subscription_name

str

Required

The subscription to be deleted.

Return type

None

delete_topic

Delete a topic.

async delete_topic(topic_name: str, **kwargs) -> None

Parameters

topic_name

str

Required

The topic to be deleted.

Return type

None

from_connection_string

Create a client from connection string.

from_connection_string(conn_str: str, **kwargs: Any) -> azure.servicebus.aio.management._management_client_async.ServiceBusAdministrationClient

Parameters

conn_str

str

Required

The connection string of the Service Bus Namespace.

api_version

str

The Service Bus API version to use for requests. Default value is the most recent service version that is compatible with the current SDK. Setting to an older version may result in reduced feature compatibility.

Return type

<xref:azure.servicebus.management.aio.ServiceBusAdministrationClient>

get_namespace_properties

Get the namespace properties

async get_namespace_properties(**kwargs) -> azure.servicebus.management._models.NamespaceProperties

Return type

NamespaceProperties

get_queue

Get the properties of a queue.

async get_queue(queue_name: str, **kwargs) -> azure.servicebus.management._models.QueueProperties

Parameters

queue_name

str

Required

The name of the queue.

Return type

QueueProperties

get_queue_runtime_properties

Get the runtime information of a queue.

async get_queue_runtime_properties(queue_name: str, **kwargs) -> azure.servicebus.management._models.QueueRuntimeProperties

Parameters

queue_name

str

Required

The name of the queue.

Return type

QueueRuntimeProperties

get_rule

Get the properties of a topic subscription rule.

async get_rule(topic_name: str, subscription_name: str, rule_name: str, **kwargs) -> azure.servicebus.management._models.RuleProperties

Parameters

topic_name

str

Required

The topic that owns the subscription.

subscription_name

str

Required

The subscription that owns the rule.

rule_name

str

Required

Name of the rule.

Return type

RuleProperties

get_subscription

Get the properties of a topic subscription.

async get_subscription(topic_name: str, subscription_name: str, **kwargs) -> azure.servicebus.management._models.SubscriptionProperties

Parameters

topic_name

str

Required

The topic that owns the subscription.

subscription_name

str

Required

name of the subscription.

Return type

SubscriptionProperties

get_subscription_runtime_properties

Get a topic subscription runtime info.

async get_subscription_runtime_properties(topic_name: str, subscription_name: str, **kwargs) -> azure.servicebus.management._models.SubscriptionRuntimeProperties

Parameters

topic_name

str

Required

The topic that owns the subscription.

subscription_name

str

Required

name of the subscription.

Return type

SubscriptionRuntimeProperties

get_topic

Get the properties of a topic.

async get_topic(topic_name: str, **kwargs) -> azure.servicebus.management._models.TopicProperties

Parameters

topic_name

str

Required

The name of the topic.

Return type

<xref:azure.servicebus.management.TopicDescription>

get_topic_runtime_properties

Get the runtime information of a topic.

async get_topic_runtime_properties(topic_name: str, **kwargs) -> azure.servicebus.management._models.TopicRuntimeProperties

Parameters

topic_name

str

Required

The name of the topic.

Return type

TopicRuntimeProperties

list_queues

List the queues of a ServiceBus namespace.

list_queues(**kwargs: Any) -> azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.QueueProperties]

Returns

An iterable (auto-paging) response of QueueProperties.

Return type

AsyncItemPaged[QueueProperties]

list_queues_runtime_properties

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

list_queues_runtime_properties(**kwargs: Any) -> azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.QueueRuntimeProperties]

Returns

An iterable (auto-paging) response of QueueRuntimeProperties.

Return type

AsyncItemPaged[QueueRuntimeProperties]

list_rules

List the rules of a topic subscription.

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

Parameters

topic_name

str

Required

The topic that owns the subscription.

subscription_name

str

Required

The subscription that owns the rules.

Returns

An iterable (auto-paging) response of RuleProperties.

Return type

AsyncItemPaged[RuleProperties]

list_subscriptions

List the subscriptions of a ServiceBus Topic.

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

Parameters

topic_name

str

Required

The topic that owns the subscription.

Returns

An iterable (auto-paging) response of SubscriptionProperties.

Return type

AsyncItemPaged[SubscriptionProperties]

list_subscriptions_runtime_properties

List the subscriptions runtime information of a ServiceBus.

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

Parameters

topic_name

str

Required

The topic that owns the subscription.

Returns

An iterable (auto-paging) response of SubscriptionRuntimeProperties.

Return type

AsyncItemPaged[SubscriptionRuntimeProperties]

list_topics

List the topics of a ServiceBus namespace.

list_topics(**kwargs: Any) -> azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.TopicProperties]

Returns

An iterable (auto-paging) response of TopicProperties.

Return type

AsyncItemPaged[TopicProperties]

list_topics_runtime_properties

List the topics runtime information of a ServiceBus namespace.

list_topics_runtime_properties(**kwargs: Any) -> azure.core.async_paging.AsyncItemPaged[azure.servicebus.management._models.TopicRuntimeProperties]

Returns

An iterable (auto-paging) response of TopicRuntimeProperties.

Return type

AsyncItemPaged[TopicRuntimeProperties]

update_queue

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. You could also pass keyword arguments for updating properties in the form of <property_name>=<property_value> which will override whatever was specified in the QueueProperties instance. Refer to ~azure.servicebus.management.QueueProperties for names of properties.

async update_queue(queue: Union[azure.servicebus.management._models.QueueProperties, Mapping[str, Any]], **kwargs) -> None

Parameters

queue

QueueProperties

Required

The queue that is returned from get_queue, create_queue or list_queues and has the updated properties.

Return type

None

update_rule

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. You could also pass keyword arguments for updating properties in the form of <property_name>=<property_value> which will override whatever was specified in the RuleProperties instance. Refer to ~azure.servicebus.management.RuleProperties for names of properties.

async update_rule(topic_name: str, subscription_name: str, rule: Union[azure.servicebus.management._models.RuleProperties, Mapping[str, Any]], **kwargs) -> None

Parameters

topic_name

str

Required

The topic that owns the subscription.

subscription_name

str

Required

The subscription that owns this rule.

rule

RuleProperties

Required

The rule that is returned from get_rule, create_rule, or list_rules and has the updated properties.

Return type

None

update_subscription

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. You could also pass keyword arguments for updating properties in the form of <property_name>=<property_value> which will override whatever was specified in the SubscriptionProperties instance. Refer to ~azure.servicebus.management.SubscriptionProperties for names of properties.

async update_subscription(topic_name: str, subscription: Union[azure.servicebus.management._models.SubscriptionProperties, Mapping[str, Any]], **kwargs) -> None

Parameters

topic_name

str

Required

The topic that owns the subscription.

subscription

SubscriptionProperties

Required

The subscription that is returned from get_subscription, update_subscription or list_subscription and has the updated properties.

Return type

None

update_topic

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. You could also pass keyword arguments for updating properties in the form of <property_name>=<property_value> which will override whatever was specified in the TopicProperties instance. Refer to ~azure.servicebus.management.TopicProperties for names of properties.

async update_topic(topic: Union[azure.servicebus.management._models.TopicProperties, Mapping[str, Any]], **kwargs) -> None

Parameters

topic

TopicProperties

Required

The topic that is returned from get_topic, create_topic, or list_topics and has the updated properties.

Return type

None