你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

servicebus 包

aio
amqp
management

模块

exceptions

AutoLockRenewer

使用后台线程池自动续订消息和会话的锁。

使用后台线程池自动续订消息和会话的锁。 当 AutoLockRenewer 应同时处理多个消息或会话时,建议将max_worker设置为大数或传递大max_workers号的 ThreadPoolExecutor。

ServiceBusClient

ServiceBusClient 类定义用于获取 ServiceBusSender 和 ServiceBusReceiver 的高级接口。

ServiceBusConnectionStringProperties

连接字符串的属性。

ServiceBusMessage

服务总线消息。

ServiceBusMessageBatch

一批消息。

与发送单个消息相比,批量发送消息的性能更高。 ServiceBusMessageBatch 可帮助创建最大允许大小的 消息 批以提高发送性能。

使用 add 方法添加消息,直到达到最大批大小限制(以字节为单位),此时将引发 MessageSizeExceededError

请使用 ServiceBusSender 的 create_message_batch 方法创建 ServiceBusMessageBatch 对象,而不是直接实例化 ServiceBusMessageBatch 对象。

ServiceBusReceivedMessage

从服务端收到的服务总线消息。

ServiceBusReceiver

ServiceBusReceiver 类定义一个高级接口,用于从Azure 服务总线队列或主题订阅接收消息。

接收消息的两个主要通道是 receive () ,用于对消息发出单个请求, 对于接收方中的消息: 持续接收传入消息。

请使用 get_<queue/subscription>_receiver ~azure.servicebus.ServiceBusClient 方法创建 ServiceBusReceiver 实例。

ServiceBusSender

ServiceBusSender 类定义一个高级接口,用于将消息发送到Azure 服务总线队列或主题。

请使用 get_<queue/topic>_sender ~azure.servicebus.ServiceBusClient 方法创建 ServiceBusSender 实例。

ServiceBusSession

ServiceBusSession 用于管理会话状态和锁定续订。

请使用 ServiceBusReceiver 上的 属性 session 获取与接收方链接的相应 ServiceBusSession 对象,而不是直接实例化 ServiceBusSession 对象。

枚举

ServiceBusMessageState
ServiceBusReceiveMode
ServiceBusSessionFilter
ServiceBusSubQueue
TransportType

传输类型 基础传输协议类型:

Amqp:基于默认 TCP 传输协议的 AMQP,它使用端口 5671。 AmqpOverWebsocket:通过 Web 套接字传输协议的 Amqp,它使用端口 443。

函数

parse_connection_string

将连接字符串分析为包含其组件部分的属性包。

parse_connection_string(conn_str: str) -> ServiceBusConnectionStringProperties

参数

名称 说明
conn_str
必需
str

必须分析的连接字符串。

返回

类型 说明

包含分析的连接字符串的属性模型。