servicebus Pacote

Renovar automaticamente bloqueios para mensagens e sessões usando um pool de threads em segundo plano.

Renovar automaticamente bloqueios para mensagens e sessões usando um pool de threads em segundo plano. É recomendável definir max_worker para um número grande ou passar ThreadPoolExecutor de número de max_workers grande quando o AutoLockRenewer deve lidar com várias mensagens ou sessões simultaneamente.

A classe ServiceBusClient define uma interface de alto nível para obter ServiceBusSender e ServiceBusReceiver.

Propriedades de uma cadeia de conexão.

Uma mensagem do Barramento de Serviço.

Um lote de mensagens.

O envio de mensagens em um lote é mais eficaz do que o envio de mensagens individuais. ServiceBusMessageBatch ajuda você a criar o lote de tamanho máximo permitido de Mensagem para melhorar o desempenho de envio.

Use o método add para adicionar mensagens até que o limite máximo de tamanho do lote em bytes seja atingido . Nesse ponto, um MessageSizeExceededError será gerado.

Use o método create_message_batch de ServiceBusSender para criar um objeto ServiceBusMessageBatch em vez de instanciar um objeto ServiceBusMessageBatch diretamente.

Uma Mensagem do Barramento de Serviço recebida do lado do serviço.

A classe ServiceBusReceiver define uma interface de alto nível para receber mensagens da fila de Barramento de Serviço do Azure ou da assinatura de tópico.

Os dois canais principais para recebimento de mensagens são receive() para fazer uma única solicitação de mensagens e para mensagem no receptor: receber continuamente mensagens de entrada de forma contínua.

Use o método de ~azure.servicebus.ServiceBusClient get_<queue/subscription>_receiver para criar uma instância de ServiceBusReceiver.

A classe ServiceBusSender define uma interface de alto nível para enviar mensagens para a Fila de Barramento de Serviço do Azure ou Tópico.

Use o método de ~azure.servicebus.ServiceBusClient get_<queue/topic>_sender para criar uma instância do ServiceBusSender.

O ServiceBusSession é usado para gerenciar estados de sessão e renovação de bloqueio.

Use a propriedade session no ServiceBusReceiver para obter o objeto ServiceBusSession correspondente vinculado ao receptor em vez de instanciar um objeto ServiceBusSession diretamente.

Tipo de transporte O tipo de protocolo de transporte subjacente:

Amqp: AMQP sobre o protocolo de transporte TCP padrão, ele usa a porta 5671. AmqpOverWebsocket: Amqp sobre o protocolo de transporte de Soquetes Web, ele usa a porta 443.