servicebus Paquet

Renouvellement automatique des verrous pour les messages et les sessions à l’aide d’un pool de threads d’arrière-plan.

Renouvellement automatique des verrous pour les messages et les sessions à l’aide d’un pool de threads d’arrière-plan. Il est recommandé de définir max_worker sur un grand nombre ou de transmettre ThreadPoolExecutor de grand max_workers nombre lorsque AutoLockRenewer est censé traiter plusieurs messages ou sessions simultanément.

La classe ServiceBusClient définit une interface de haut niveau pour obtenir ServiceBusSender et ServiceBusReceiver.

Propriétés d’une chaîne de connexion.

Message Service Bus.

Lot de messages.

L’envoi de messages dans un lot est plus performant que l’envoi d’un message individuel. ServiceBusMessageBatch vous aide à créer le lot de taille maximale autorisée de Message pour améliorer les performances d’envoi.

Utilisez la méthode add pour ajouter des messages jusqu’à ce que la limite de taille de lot maximale en octets ait été atteinte, auquel cas un MessageSizeExceededError est déclenché.

Utilisez la méthode create_message_batch de ServiceBusSender pour créer un objet ServiceBusMessageBatch au lieu d’instancier un objet ServiceBusMessageBatch directement.

Message Service Bus reçu côté service.

La classe ServiceBusReceiver définit une interface de haut niveau pour la réception de messages de l’abonnement file d’attente ou rubrique Azure Service Bus.

Les deux principaux canaux de réception de message sont receive() pour effectuer une requête unique pour les messages, et pour le message dans le destinataire : pour recevoir en continu les messages entrants.

Utilisez la get_<queue/subscription>_receiver méthode ~azure.servicebus.ServiceBusClient pour créer une instance ServiceBusReceiver.

La classe ServiceBusSender définit une interface de haut niveau pour l’envoi de messages à la file d’attente ou à la rubrique Azure Service Bus.

Utilisez la get_<queue/topic>_sender méthode ~azure.servicebus.ServiceBusClient pour créer un instance ServiceBusSender.

ServiceBusSession est utilisé pour gérer les états de session et le renouvellement des verrous.

Utilisez la propriété session sur le ServiceBusReceiver pour obtenir l’objet ServiceBusSession correspondant lié au récepteur au lieu d’instancier directement un objet ServiceBusSession.

Type de transport Type de protocole de transport sous-jacent :

Amqp : AMQP sur le protocole de transport TCP par défaut, il utilise le port 5671. AmqpOverWebsocket : Amqp via le protocole de transport Web Sockets, il utilise le port 443.