servicebus Пакет

Автоматическое продление блокировки сообщений и сеансов с помощью пула фоновых потоков.

Автоматическое продление блокировки сообщений и сеансов с помощью пула фоновых потоков. Рекомендуется задать max_worker большое число или передать ThreadPoolExecutor большого числа max_workers, если AutoLockRenewer должен одновременно работать с несколькими сообщениями или сеансами.

Класс ServiceBusClient определяет высокоуровневый интерфейс для получения ServiceBusSender и ServiceBusReceiver.

Свойства строки подключения.

Сообщение служебной шины.

Пакет сообщений.

Отправка сообщений в пакете более эффективна, чем отправка отдельных сообщений. ServiceBusMessageBatch помогает создать максимально допустимый размер пакета message для повышения производительности отправки.

Используйте метод add для добавления сообщений, пока не будет достигнут максимальный размер пакета в байтах. В этот момент будет возникать messageSizeExceededError .

Используйте метод create_message_batch ServiceBusSender для создания объекта ServiceBusMessageBatch вместо непосредственного создания экземпляра объекта ServiceBusMessageBatch.

Сообщение служебной шины, полученное со стороны службы.

Класс ServiceBusReceiver определяет высокоуровневый интерфейс для получения сообщений из очереди Служебная шина Azure или подписки раздела.

Двумя основными каналами для получения сообщений являются receive() для выполнения единого запроса сообщений, а для сообщения в получателе — для непрерывного получения входящих сообщений.

Используйте get_<queue/subscription>_receiver метод ~azure.servicebus.ServiceBusClient для создания экземпляра ServiceBusReceiver.

Класс ServiceBusSender определяет высокоуровневый интерфейс для отправки сообщений в очередь или раздел Служебная шина Azure.

Используйте get_<queue/topic>_sender метод ~azure.servicebus.ServiceBusClient для создания экземпляра ServiceBusSender.

ServiceBusSession используется для управления состояниями сеанса и возобновления блокировки.

Используйте свойство session ServiceBusReceiver, чтобы получить соответствующий объект ServiceBusSession, связанный с получателем, вместо непосредственного создания экземпляра объекта ServiceBusSession.

Тип транспорта. Базовый тип транспортного протокола:

Amqp: AMQP по транспортному протоколу TCP по умолчанию, используется порт 5671. AmqpOverWebsocket: amqp через транспортный протокол Web Sockets, он использует порт 443.