servicebus パッケージ

パッケージ

aio
amqp
management

モジュール

exceptions

クラス

AutoLockRenewer

バックグラウンド スレッド プールを使用してメッセージとセッションのロックを自動更新します。

バックグラウンド スレッド プールを使用してメッセージとセッションのロックを自動更新します。 AutoLockRenewer が複数のメッセージまたはセッションを同時に処理することが想定されている場合は、max_workerを大きな数に設定するか、大きなmax_workers数の ThreadPoolExecutor を渡すことをお勧めします。

ServiceBusClient

ServiceBusClient クラスは、ServiceBusSender と ServiceBusReceiver を取得するための高度なインターフェイスを定義します。

ServiceBusConnectionStringProperties

接続文字列のプロパティ。

ServiceBusMessage

Service Bus メッセージ。

ServiceBusMessageBatch

メッセージのバッチ。

バッチでのメッセージの送信は、個々のメッセージを送信するよりもパフォーマンスが高くなります。 ServiceBusMessageBatch は、 メッセージ の最大許容サイズ バッチを作成して送信パフォーマンスを向上させるのに役立ちます。

add メソッドを使用して、最大バッチ サイズ制限 (バイト単位) に達するまでメッセージを追加します。この時点で MessageSizeExceededError が発生します。

ServiceBusSender の create_message_batch メソッドを使用して、ServiceBusMessageBatch オブジェクトを直接インスタンス化するのではなく、ServiceBusMessageBatch オブジェクトを作成してください。

ServiceBusReceivedMessage

サービス側から受信した Service Bus メッセージ。

ServiceBusReceiver

ServiceBusReceiver クラスは、Azure Service Bus キューまたはトピック サブスクリプションからメッセージを受信するための高レベルのインターフェイスを定義します。

メッセージ受信の 2 つの主要なチャネルは、メッセージに対して 1 つの要求を行う receive()、受信側のメッセージ の場合は、継続的な方法で受信メッセージを継続的に受信するための receive() です。

~azure.servicebus.ServiceBusClient のメソッドを使用 get_<queue/subscription>_receiver して、ServiceBusReceiver インスタンスを作成してください。

ServiceBusSender

ServiceBusSender クラスは、Azure Service Bus キューまたはトピックにメッセージを送信するための高度なインターフェイスを定義します。

~azure.servicebus.ServiceBusClient のメソッドを使用 get_<queue/topic>_sender して、ServiceBusSender インスタンスを作成してください。

ServiceBusSession

ServiceBusSession は、セッション状態の管理とロックの更新に使用されます。

ServiceBusSession オブジェクトを直接インスタンス化するのではなく、ServiceBusReceiver の プロパティ session を使用して、受信側にリンクされた対応する ServiceBusSession オブジェクトを取得してください。

列挙型

ServiceBusMessageState
ServiceBusReceiveMode
ServiceBusSessionFilter
ServiceBusSubQueue
TransportType

トランスポートの種類 基になるトランスポート プロトコルの種類:

Amqp: 既定の TCP トランスポート プロトコル経由の AMQP。ポート 5671 が使用されます。 AmqpOverWebsocket: Amqp over the Web Sockets transport protocol, it uses port 443.

機能

parse_connection_string

接続文字列を、そのコンポーネント パーツを含むプロパティ バッグに解析します。

parse_connection_string(conn_str: str) -> ServiceBusConnectionStringProperties

パラメーター

名前 説明
conn_str
必須
str

解析する必要がある接続文字列。

戻り値

説明

解析された接続文字列を含むプロパティ モデル。