servicebus Paket

Pakete

aio
amqp
management

Module

exceptions

Klassen

AutoLockRenewer

Automatische Verlängerung von Sperren für Nachrichten und Sitzungen mithilfe eines Hintergrundthreadpools.

Automatische Verlängerung von Sperren für Nachrichten und Sitzungen mithilfe eines Hintergrundthreadpools. Es wird empfohlen, max_worker auf eine große Anzahl festzulegen oder ThreadPoolExecutor mit großen max_workers Zahl zu übergeben, wenn AutoLockRenewer mehrere Nachrichten oder Sitzungen gleichzeitig behandeln soll.

ServiceBusClient

Die ServiceBusClient-Klasse definiert eine allgemeine Schnittstelle zum Abrufen von ServiceBusSender und ServiceBusReceiver.

ServiceBusConnectionStringProperties

Eigenschaften einer Verbindungszeichenfolge.

ServiceBusMessage

Eine Service Bus-Nachricht.

ServiceBusMessageBatch

Ein Batch von Nachrichten.

Das Senden von Nachrichten in einem Batch ist leistungsfähiger als das Senden einzelner Nachrichten. ServiceBusMessageBatch hilft Ihnen beim Erstellen der maximal zulässigen Nachrichtengröße , um die Sendeleistung zu verbessern.

Verwenden Sie die add-Methode , um Nachrichten hinzuzufügen, bis die maximale Batchgröße in Byte erreicht ist. An diesem Punkt wird ein MessageSizeExceededError ausgelöst.

Verwenden Sie die create_message_batch Methode von ServiceBusSender, um ein ServiceBusMessageBatch-Objekt zu erstellen, anstatt ein ServiceBusMessageBatch-Objekt direkt zu instanziieren.

ServiceBusReceivedMessage

Eine Service Bus-Nachricht, die von der Dienstseite empfangen wird.

ServiceBusReceiver

Die ServiceBusReceiver-Klasse definiert eine allgemeine Schnittstelle zum Empfangen von Nachrichten aus dem Azure Service Bus Queue oder Topic Subscription.

Die beiden primären Kanäle für den Nachrichtenempfang sind receive(), um eine einzelne Anforderung für Nachrichten zu stellen, und für Nachrichten im Empfänger: fortlaufend eingehende Nachrichten zu empfangen.

Verwenden Sie die get_<queue/subscription>_receiver -Methode von ~azure.servicebus.ServiceBusClient, um eine ServiceBusReceiver-instance zu erstellen.

ServiceBusSender

Die ServiceBusSender-Klasse definiert eine allgemeine Schnittstelle zum Senden von Nachrichten an die Azure Service Bus Queue oder Topic.

Verwenden Sie die get_<queue/topic>_sender -Methode von ~azure.servicebus.ServiceBusClient, um einen ServiceBusSender-instance zu erstellen.

ServiceBusSession

Die ServiceBusSession wird zum Verwalten von Sitzungszuständen und zur Verlängerung von Sperren verwendet.

Verwenden Sie die -Eigenschaft session für serviceBusReceiver, um das entsprechende ServiceBusSession-Objekt abzurufen, das mit dem Empfänger verknüpft ist, anstatt ein ServiceBusSession-Objekt direkt zu instanziieren.

Enumerationen

ServiceBusMessageState
ServiceBusReceiveMode
ServiceBusSessionFilter
ServiceBusSubQueue
TransportType

Transporttyp Der zugrunde liegende Transportprotokolltyp:

Amqp: AMQP über das standardmäßige TCP-Transportprotokoll verwendet Port 5671. AmqpOverWebsocket: Amqp über das Web Sockets-Transportprotokoll verwendet Port 443.

Functions

parse_connection_string

Analysieren Sie die Verbindungszeichenfolge in einen Eigenschaftenbehälter, der die Komponententeile enthält.

parse_connection_string(conn_str: str) -> ServiceBusConnectionStringProperties

Parameter

Name Beschreibung
conn_str
Erforderlich
str

Die Verbindungszeichenfolge, die analysiert werden muss.

Gibt zurück

Typ Beschreibung

Ein Eigenschaftenmodell, das die analysierte Verbindungszeichenfolge enthält.