servicebus Pakiet

Pakiety

aio
amqp
management

Moduły

exceptions

Klasy

AutoLockRenewer

Automatyczne odnawianie blokad dla komunikatów i sesji przy użyciu puli wątków w tle.

Automatyczne odnawianie blokad dla komunikatów i sesji przy użyciu puli wątków w tle. Zaleca się ustawienie max_worker do dużej liczby lub przekazanie elementu ThreadPoolExecutor dużej liczby max_workers, gdy funkcja AutoLockRenewer ma obsługiwać wiele komunikatów lub sesji jednocześnie.

ServiceBusClient

Klasa ServiceBusClient definiuje interfejs wysokiego poziomu na potrzeby pobierania usług ServiceBusSender i ServiceBusReceiver.

ServiceBusConnectionStringProperties

Właściwości parametrów połączenia.

ServiceBusMessage

Komunikat usługi Service Bus.

ServiceBusMessageBatch

Partia komunikatów.

Wysyłanie komunikatów w partii jest bardziej wydajne niż wysyłanie pojedynczej wiadomości. Usługa ServiceBusMessageBatch pomaga utworzyć maksymalną dozwoloną partię komunikatów w celu zwiększenia wydajności wysyłania.

Użyj metody add , aby dodać komunikaty do momentu osiągnięcia maksymalnego limitu rozmiaru partii w bajtach — w którym momencie zostanie podniesiony błąd MessageSizeExceededError .

Użyj create_message_batch metody ServiceBusSender, aby utworzyć obiekt ServiceBusMessageBatch zamiast utworzyć wystąpienie obiektu ServiceBusMessageBatch bezpośrednio.

ServiceBusReceivedMessage

Komunikat usługi Service Bus odebrany po stronie usługi.

ServiceBusReceiver

Klasa ServiceBusReceiver definiuje interfejs wysokiego poziomu do odbierania komunikatów z Azure Service Bus kolejki lub subskrypcji tematu.

Dwa główne kanały odbioru komunikatów są odbierane () w celu utworzenia pojedynczego żądania dla komunikatów i komunikatu w odbiorniku: ciągłego odbierania przychodzących komunikatów w sposób ciągły.

Użyj get_<queue/subscription>_receiver metody ~azure.servicebus.ServiceBusClient, aby utworzyć wystąpienie klasy ServiceBusReceiver.

ServiceBusSender

Klasa ServiceBusSender definiuje interfejs wysokiego poziomu do wysyłania komunikatów do kolejki Azure Service Bus lub tematu.

Użyj get_<queue/topic>_sender metody ~azure.servicebus.ServiceBusClient, aby utworzyć wystąpienie usługi ServiceBusSender.

ServiceBusSession

Usługa ServiceBusSession jest używana do zarządzania stanami sesji i odnawiania blokady.

Użyj właściwości session w obiekcie ServiceBusReceiver, aby uzyskać odpowiedni obiekt ServiceBusSession połączony z odbiornikiem zamiast bezpośrednio utworzyć wystąpienie obiektu ServiceBusSession.

Wyliczenia

ServiceBusMessageState
ServiceBusReceiveMode
ServiceBusSessionFilter
ServiceBusSubQueue
TransportType

Typ transportu Podstawowy typ protokołu transportowego:

Amqp: AMQP za pośrednictwem domyślnego protokołu transportu TCP, używa portu 5671. AmqpOverWebsocket: Amqp za pośrednictwem protokołu transportu Web Sockets, używa portu 443.

Funkcje

parse_connection_string

Przeanalizuj parametry połączenia do torby właściwości zawierającej jej części składowe.

parse_connection_string(conn_str: str) -> ServiceBusConnectionStringProperties

Parametry

Nazwa Opis
conn_str
Wymagane
str

Parametry połączenia, które muszą być analizowane.

Zwraca

Typ Opis

Model właściwości zawierający przeanalizowane parametry połączenia.