servicebus Paket

Paket

aio
amqp
management

Moduler

exceptions

Klasser

AutoLockRenewer

Automatisk förnyelse av lås för meddelanden och sessioner med hjälp av en bakgrundstrådspool.

Automatisk förnyelse av lås för meddelanden och sessioner med hjälp av en bakgrundstrådspool. Vi rekommenderar att du anger max_worker till ett stort antal eller skickar ThreadPoolExecutor för stora max_workers tal när AutoLockRenewer ska hantera flera meddelanden eller sessioner samtidigt.

ServiceBusClient

Klassen ServiceBusClient definierar ett högnivågränssnitt för att hämta ServiceBusSender och ServiceBusReceiver.

ServiceBusConnectionStringProperties

Egenskaper för en anslutningssträng.

ServiceBusMessage

Ett Service Bus-meddelande.

ServiceBusMessageBatch

En batch med meddelanden.

Att skicka meddelanden i en batch är mer högpresterande än att skicka enskilda meddelanden. ServiceBusMessageBatch hjälper dig att skapa batchen för maximal tillåten storlek för Meddelande för att förbättra sändningsprestanda.

Använd metoden lägg till för att lägga till meddelanden tills den maximala batchstorleksgränsen i byte har nåtts . Då aktiveras en MessageSizeExceededError .

Använd create_message_batch-metoden för ServiceBusSender för att skapa ett ServiceBusMessageBatch-objekt i stället för att instansiera ett ServiceBusMessageBatch-objekt direkt.

ServiceBusReceivedMessage

Ett Service Bus-meddelande som tagits emot från tjänstsidan.

ServiceBusReceiver

Klassen ServiceBusReceiver definierar ett högnivågränssnitt för att ta emot meddelanden från Azure Service Bus-kö eller ämnesprenumeration.

De två primära kanalerna för meddelandekvitto är receive() för att göra en enda begäran om meddelanden och för meddelande i mottagaren: att kontinuerligt ta emot inkommande meddelanden på ett pågående sätt.

get_<queue/subscription>_receiver Använd metoden ~azure.servicebus.ServiceBusClient för att skapa en ServiceBusReceiver-instans.

ServiceBusSender

Klassen ServiceBusSender definierar ett gränssnitt på hög nivå för att skicka meddelanden till Azure Service Bus kö eller ämne.

get_<queue/topic>_sender Använd metoden ~azure.servicebus.ServiceBusClient för att skapa en ServiceBusSender-instans.

ServiceBusSession

ServiceBusSession används för att hantera sessionstillstånd och låsa förnyelse.

Använd egenskapen session på ServiceBusReceiver för att få motsvarande ServiceBusSession-objekt länkat till mottagaren i stället för att instansiera ett ServiceBusSession-objekt direkt.

Uppräkningar

ServiceBusMessageState
ServiceBusReceiveMode
ServiceBusSessionFilter
ServiceBusSubQueue
TransportType

Transporttyp Den underliggande transportprotokolltypen:

Amqp: AMQP över standardprotokollet för TCP-transport använder port 5671. AmqpOverWebsocket: Amqp över transportprotokollet Web Sockets använder port 443.

Funktioner

parse_connection_string

Parsa anslutningssträngen i en egenskapspåse som innehåller dess komponentdelar.

parse_connection_string(conn_str: str) -> ServiceBusConnectionStringProperties

Parametrar

Name Description
conn_str
Obligatorisk
str

Anslutningssträngen som måste parsas.

Returer

Typ Description

En egenskapsmodell som innehåller den tolkade anslutningssträngen.