Краткое руководство. Отправка и получение больших сообщений с помощью Центров событий Azure

Из этого краткого руководства вы узнаете, как отправлять и получать большие сообщения (до 20 МБ) с помощью Центры событий Azure. Если вы не знакомы с Центрами событий, ознакомьтесь с обзором Центров событий перед началом работы.

Необходимые компоненты

Настройка выделенного кластера Центров событий

Для потоковой передачи больших сообщений необходимо настроить масштабируемый выделенный кластер самостоятельно.

В портал Azure перейдите в раздел "Параметры" для выделенного кластера. В разделе "Параметры" выберите вкладку "Квота".

Снимок экрана: панель квот для выделенного кластера.

  • Убедитесь, что для ключа supportslargemessages только для чтения задано Trueзначение.
  • Ключ eventhubmaxmessagesizeinbytes можно обновить до подходящего значения в байтах. Допустимый диапазон для этого значения составляет от 1048 576 до 20 971 520 байт.

После сохранения конфигурации вы будете готовы передавать большие сообщения с помощью Центров событий.

Внимание

Потоковая передача больших сообщений поддерживается только с масштабируемыми выделенными кластерами, созданными на основе последней инфраструктуры. Ключ Supportslargemessages отражает эту возможность.

Если значение кластера равно false, оно не поддерживает потоковую передачу больших сообщений. Чтобы включить эту функцию, необходимо повторно создать кластер. Стриминг больших сообщений не требует дополнительных затрат.

Потоковая передача больших сообщений с помощью Центров событий

Допустимые центры событий самообслуживания позволяют потоковую передачу больших сообщений до 20 МБ, как в пакетах, так и в виде отдельных публикаций. Вы можете использовать любой существующий пакет SDK центров событий или API Kafka для потоковой передачи больших сообщений в Центры событий. Для существующих подключений перезапустите клиенты или повторно установите подключение для потоковой передачи больших сообщений.

Дополнительные сведения см. в разделе "Отправка событий в Центры событий" и получение событий с помощью .NET.

Совет

Обязательно просмотрите любой клиент расширенного протокола очереди сообщений (AMQP) или конфигурацию клиента Kafka, который может ограничить максимальный размер сообщения, который вы передаете в Центры событий. Необходимо обновить время ожидания клиента до более высокого значения (> 60-х) для потоковой передачи большого сообщения и уточнить его на основе результатов тестирования в соответствии с потребностями рабочей нагрузки.

По умолчанию число предварительных выборок клиента AMQP равно 300. Уменьшите это значение, чтобы избежать проблем с памятью на стороне клиента при решении больших сообщений.

Полный справочник по пакету SDK см. в библиотеках Центров событий Azure для .NET.