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

參數

名稱 Description
conn_str
必要
str

必須剖析的連接字串。

傳回

類型 Description

包含已剖析連接字串的屬性模型。