Доступные методы для отслеживания размера очереди проверок концентратора событий Azure

Question

Кафка предоставляет возможность контролировать текущее смещение и последнее смещение.Точно так же Azure Eventhub предоставляет какой-либо API для постоянного мониторинга текущего смещения раздела и последнего доступного смещения?

Answer 1

Расширяя ответ выше, вы можете увидеть смещение двумя способами.

1. Смещение печати в файле журнала, где вы слушаете EventHub

, например, с помощью функции Azure

    public static async Task Run([EventHubTrigger("EventHubname", ConsumerGroup = "ConsumerGroupname", Connection = "EventHubConnection")]EventData eventMessage,
        [Inject]IService service, [Inject]ILog log)
    {
    log.Info($"PartitionKey {eventMessage.PartitionKey}, Offset {eventMessage.Offset} and SequenceNumber {eventMessage.SequenceNumber}");
    }

Я слушаю Eventhub по функциям Azure. Ниже вы можете увидеть расположение, в котором функция Azure поддерживает смещение по разделам.

Вариант 3 (последний)

Смещение не является правильным способом измерения глубины Eventhub, особенно если вы хотите проверить, сколько сообщений нужно обработать.

Теперь мыиспользуя Eventhub сообщение SequenceNumber вместо Offset.Мы создали функцию TimerTrigger Azure.Каждые 5 минут мы получаем LastEnqueuedSequenceNumber из Eventhub и SequenceNumber для каждого раздела из хранилища BLOB-объектов (расположение контрольных точек), затем мы сохраняем разницу в пользовательских метриках ApplicationInsight.

Затем ApplicationInsights помогает нам вводить информацию о глубине Eventhub в панели мониторинга Azure и настраивать оповещения.

Запуск по таймеруКод

Надеюсь, это поможет!

Answer 2

Просмотр Функции и терминология в концентраторах событий Azure - Потребители событий - Смещения потока :

Смещение - это позиция события в разделе.Вы можете рассматривать смещение как курсор на стороне клиента.Смещение - это байтовая нумерация события.Это смещение позволяет потребителю (читателю) события указать в потоке событий точку, с которой он хочет начать чтение событий.Вы можете указать смещение как метку времени или как значение смещения. Потребители несут ответственность за хранение своих собственных значений смещения вне службы концентраторов событий. В пределах раздела каждое событие включает смещение.

А также в разделе Распространенные потребительские задачи- Чтение событий :

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

По-видимому, нет никаких методов, которые вы можете использовать для контроля смещения, поскольку вам нужно сделать это самостоятельно.