Delen via


servicebus Pakket

Pakketten

aio
amqp
management

Modules

exceptions

Klassen

AutoLockRenewer

Automatisch verlengen vergrendelt berichten en sessies met behulp van een achtergrondthreadgroep.

Automatisch verlengen vergrendelt berichten en sessies met behulp van een achtergrondthreadgroep. Het wordt aanbevolen max_worker in te stellen op een groot aantal of ThreadPoolExecutor van een groot max_workers getal door te geven wanneer AutoLockRenewer meerdere berichten of sessies tegelijk moet verwerken.

ServiceBusClient

De ServiceBusClient-klasse definieert een interface op hoog niveau voor het ophalen van ServiceBusSender en ServiceBusReceiver.

ServiceBusConnectionStringProperties

Eigenschappen van een connection string.

ServiceBusMessage

Een Service Bus-bericht.

ServiceBusMessageBatch

Een batch berichten.

Het verzenden van berichten in een batch is beter dan het verzenden van afzonderlijke berichten. ServiceBusMessageBatch helpt u bij het maken van de maximaal toegestane batch van bericht om de verzendprestaties te verbeteren.

Gebruik de add-methode om berichten toe te voegen totdat de maximale batchgroottelimiet in bytes is bereikt. Op dat moment wordt een MessageSizeExceededError verhoogd.

Gebruik de create_message_batch methode van ServiceBusSender om een ServiceBusMessageBatch-object te maken in plaats van rechtstreeks een ServiceBusMessageBatch-object te instantiëren.

ServiceBusReceivedMessage

Een Service Bus-bericht dat is ontvangen van de servicezijde.

ServiceBusReceiver

De ServiceBusReceiver-klasse definieert een interface op hoog niveau voor het ontvangen van berichten van de Azure Service Bus Queue of Topic Subscription.

De twee primaire kanalen voor de ontvangst van berichten zijn receive() om één aanvraag voor berichten te doen en voor bericht in ontvanger: om continu inkomende berichten op een doorlopende manier te ontvangen.

Gebruik de get_<queue/subscription>_receiver methode ~azure.servicebus.ServiceBusClient om een ServiceBusReceiver-exemplaar te maken.

ServiceBusSender

De ServiceBusSender-klasse definieert een interface op hoog niveau voor het verzenden van berichten naar de Azure Service Bus wachtrij of onderwerp.

Gebruik de get_<queue/topic>_sender methode ~azure.servicebus.ServiceBusClient om een ServiceBusSender-exemplaar te maken.

ServiceBusSession

ServiceBusSession wordt gebruikt voor het beheren van sessiestatussen en het vergrendelen van verlenging.

Gebruik de eigenschap session op de ServiceBusReceiver om het bijbehorende ServiceBusSession-object op te halen dat is gekoppeld aan de ontvanger in plaats van rechtstreeks een ServiceBusSession-object te instantiëren.

Enums

ServiceBusMessageState
ServiceBusReceiveMode
ServiceBusSessionFilter
ServiceBusSubQueue
TransportType

Transporttype Het onderliggende type transportprotocol:

Amqp: AMQP via het standaard TCP-transportprotocol gebruikt poort 5671. AmqpOverWebsocket: Amqp via het websockets-transportprotocol gebruikt poort 443.

Functies

parse_connection_string

Parseert de connection string in een eigenschappenverzameling met de bijbehorende onderdelen.

parse_connection_string(conn_str: str) -> ServiceBusConnectionStringProperties

Parameters

Name Description
conn_str
Vereist
str

De connection string die moet worden geparseerd.

Retouren

Type Description

Een eigenschappenmodel met de geparseerde connection string.