servicebus Balíček

Balíčky

aio
amqp
management

Moduly

exceptions

Třídy

AutoLockRenewer

Automatické prodlužování zámků pro zprávy a relace pomocí fondu vláken na pozadí

Automatické prodlužování zámků pro zprávy a relace pomocí fondu vláken na pozadí Doporučuje se nastavit max_worker na velký počet nebo předání ThreadPoolExecutoru velkého max_workers čísla, když autoLockRenewer má pracovat s více zprávami nebo relacemi současně.

ServiceBusClient

Třída ServiceBusClient definuje rozhraní vysoké úrovně pro získání ServiceBusSender a ServiceBusReceiver.

ServiceBusConnectionStringProperties

Vlastnosti připojovacího řetězce

ServiceBusMessage

Zpráva služby Service Bus.

ServiceBusMessageBatch

Dávka zpráv.

Odesílání zpráv v dávce je výkonnější než odesílání jednotlivých zpráv. ServiceBusMessageBatch pomáhá vytvořit maximální povolenou velikost dávky zprávy , aby se zlepšil výkon odesílání.

Pomocí metody add přidejte zprávy, dokud nebude dosaženo maximálního limitu velikosti dávky v bajtech – v tomto okamžiku bude vyvolána chyba MessageSizeExceededError .

Použijte metodu create_message_batch ServiceBusSender k vytvoření objektu ServiceBusMessageBatch místo přímé instance objektu ServiceBusMessageBatch.

ServiceBusReceivedMessage

Zpráva služby Service Bus přijatá ze strany služby

ServiceBusReceiver

ServiceBusReceiver Třída definuje rozhraní vysoké úrovně pro příjem zpráv z odběru Azure Service Bus fronty nebo tématu.

Dva primární kanály pro příjem zpráv jsou receive() pro vytvoření jediného požadavku na zprávy a pro zprávy v příjemci: nepřetržitě přijímat příchozí zprávy průběžným způsobem.

K vytvoření instance ServiceBusReceiver použijte get_<queue/subscription>_receiver metodu ~azure.servicebus.ServiceBusClient.

ServiceBusSender

ServiceBusSender Třída definuje rozhraní vysoké úrovně pro odesílání zpráv do Azure Service Bus fronty nebo tématu.

K vytvoření instance ServiceBusSender použijte get_<queue/topic>_sender metodu ~azure.servicebus.ServiceBusClient.

ServiceBusSession

ServiceBusSession slouží ke správě stavů relací a prodlužování uzamčení.

Pomocí vlastnosti session ServiceBusReceiver získejte odpovídající objekt ServiceBusSession propojený s příjemcem místo přímé instance objektu ServiceBusSession.

Výčty

ServiceBusMessageState
ServiceBusReceiveMode
ServiceBusSessionFilter
ServiceBusSubQueue
TransportType

Typ přenosu Základní typ přenosového protokolu:

Amqp: AMQP přes výchozí přenosový protokol TCP, používá port 5671. AmqpOverWebsocket: Amqp přes přenosový protokol webových soketů používá port 443.

Funkce

parse_connection_string

Parsujte připojovací řetězec do kontejneru vlastností obsahujícího jeho součásti.

parse_connection_string(conn_str: str) -> ServiceBusConnectionStringProperties

Parametry

Name Description
conn_str
Vyžadováno
str

Připojovací řetězec, který se má analyzovat.

Návraty

Typ Description

Model vlastností obsahující analyzovaný připojovací řetězec.