Использование сжатия журналов

В этой статье показано, как использовать функцию сжатия журналов в Центрах событий. Сведения о сжатиях журналов см. в разделе Log Compaction.

В этой статье вы последуете следующим ключевым шагам.

  • Создайте компактный концентратор событий или раздел Kafka.
  • Публиковать события в компактированном концентраторе событий.
  • Использование событий из компактного концентратора событий.

Замечание

Функция сжатия журналов не поддерживается на уровне "Базовый ".

Создание компактного концентратора событий или раздела Kafka

В этом разделе показано, как создать компактный концентратор событий с помощью портала Azure и шаблона Azure Resource Manager (ARM).

Вы можете создать компактный концентратор событий с помощью портала Azure, выполнив следующие действия.

  1. Перейдите в пространство имен Event Hubs.
  2. На странице пространства имен Event Hubs выберите Центры событий в меню слева.
  3. В верхней части окна выберите +Центры событий. Снимок экрана: пользовательский интерфейс создания концентратора событий.
  4. Введите имя концентратора событий и укажите число секций. Так как мы создадим компактный концентратор событий, выберите политику сжатия в качестве сжатия и предоставьте требуемое значение для времени хранения камней. Снимок экрана: пользовательский интерфейс создания центров событий с соответствующими атрибутами сжатия.
  5. Выберите создать и создайте компактный концентратор событий.

Активация сжатия

Служба Центров событий определяет, когда должно выполняться задание сжатия заданного сжатого концентратора событий. Компактный концентратор событий достигает порогового значения сжатия, если имеется значительное количество событий или общий размер заданного журнала событий значительно увеличивается.

Публикация события в сжатом разделе

Публикация событий в компактный концентратор событий точно такая же, как публикация событий в обычный концентратор событий. В качестве клиентского приложения вам нужно только определить ключ сжатия, который вы устанавливаете с помощью ключа партиции.

Использование пакета SDK центров событий (AMQP)

С помощью пакета SDK центров событий можно задать ключ секции и опубликовать события, как показано ниже:

var enqueueOptions = new EnqueueEventOptions
{
    PartitionKey = "Key-1"
    
};
await producer.EnqueueEventAsync(eventData, enqueueOptions);

Использование Kafka

С помощью Kafka можно задать ключ партиции при создании ProducerRecord, как показано ниже.

ProducerRecord<String, String> record = new ProducerRecord<String, String>(TOPIC, "Key-1" , "Value-1");

Квоты и ограничения

Лимит Базовый Стандарт Премия Dedicated
Размер сжатого концентратора событий N/A 1 ГБ на секцию 250 ГБ на секцию 250 ГБ на секцию

Дополнительные сведения о квотах и ограничениях см. в разделе " Квоты и ограничения Центров событий".

Использование событий из сжатого раздела

На стороне потребителя изменения не требуются для использования событий из компактного концентратора событий. Таким образом, вы можете использовать любое из существующих потребительских приложений для использования данных из компактного концентратора событий.

Дальнейшие шаги

  • Концептуальная информация о том, как работает сжатие журналов, см. в разделе Сжатие журналов.
  • Last updated on