你当前正在访问 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 () ,用于对消息发出单个请求, 对于接收方中的消息: 持续接收传入消息。 请使用 |
ServiceBusSender |
ServiceBusSender 类定义一个高级接口,用于将消息发送到Azure 服务总线队列或主题。 请使用 |
ServiceBusSession |
ServiceBusSession 用于管理会话状态和锁定续订。 请使用 ServiceBusReceiver 上的 属性 |
枚举
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
必需
|
必须分析的连接字符串。 |
返回
类型 | 说明 |
---|---|
包含分析的连接字符串的属性模型。 |