servicebus Paquete

Paquetes

aio
amqp
management

Módulos

exceptions

Clases

AutoLockRenewer

Renovación automática de bloqueos para mensajes y sesiones mediante un grupo de subprocesos en segundo plano.

Renovación automática de bloqueos para mensajes y sesiones mediante un grupo de subprocesos en segundo plano. Se recomienda establecer max_worker en un gran número o pasar ThreadPoolExecutor de gran max_workers número cuando Se supone que AutoLockRenewer se ocupa de varios mensajes o sesiones simultáneamente.

ServiceBusClient

La clase ServiceBusClient define una interfaz de alto nivel para obtener ServiceBusSender y ServiceBusReceiver.

ServiceBusConnectionStringProperties

Propiedades de una cadena de conexión.

ServiceBusMessage

Un mensaje de Service Bus.

ServiceBusMessageBatch

Un lote de mensajes.

El envío de mensajes en un lote es más eficaz que el envío de mensajes individuales. ServiceBusMessageBatch le ayuda a crear el lote de tamaño máximo permitido de Message para mejorar el rendimiento del envío.

Use el método add para agregar mensajes hasta que se alcance el límite máximo de tamaño de lote en bytes, momento en el que se generará un messageSizeExceededError .

Use el método create_message_batch de ServiceBusSender para crear un objeto ServiceBusMessageBatch en lugar de crear instancias de un objeto ServiceBusMessageBatch directamente.

ServiceBusReceivedMessage

Un mensaje de Service Bus recibido del lado del servicio.

ServiceBusReceiver

La clase ServiceBusReceiver define una interfaz de alto nivel para recibir mensajes de la suscripción de Azure Service Bus Cola o Tema.

Los dos canales principales para la recepción de mensajes son receive() para realizar una única solicitud de mensajes y para el mensaje en el receptor: para recibir continuamente los mensajes entrantes de forma continua.

Use el get_<queue/subscription>_receiver método de ~azure.servicebus.ServiceBusClient para crear una instancia de ServiceBusReceiver.

ServiceBusSender

La clase ServiceBusSender define una interfaz de alto nivel para enviar mensajes a la cola o el tema de Azure Service Bus.

Use el get_<queue/topic>_sender método de ~azure.servicebus.ServiceBusClient para crear una instancia de ServiceBusSender.

ServiceBusSession

ServiceBusSession se usa para administrar los estados de sesión y la renovación del bloqueo.

Use la propiedad session en ServiceBusReceiver para obtener el objeto ServiceBusSession correspondiente vinculado con el receptor en lugar de crear instancias de un objeto ServiceBusSession directamente.

Enumeraciones

ServiceBusMessageState
ServiceBusReceiveMode
ServiceBusSessionFilter
ServiceBusSubQueue
TransportType

Tipo de transporte El tipo de protocolo de transporte subyacente:

Amqp: AMQP a través del protocolo de transporte TCP predeterminado, usa el puerto 5671. AmqpOverWebsocket: Amqp a través del protocolo de transporte de web Sockets, usa el puerto 443.

Funciones

parse_connection_string

Analice la cadena de conexión en un contenedor de propiedades que contiene sus partes de componente.

parse_connection_string(conn_str: str) -> ServiceBusConnectionStringProperties

Parámetros

Nombre Description
conn_str
Requerido
str

Cadena de conexión que se debe analizar.

Devoluciones

Tipo Description

Modelo de propiedades que contiene la cadena de conexión analizada.