Event Hub Listener - получите все сообщения за один раз

Question

Я тестирую Event Hub. Разработчики отправляют сообщения в Event Hub. Я построил Event Hub Listener, чтобы проверить, что все сообщения отправляются / принимаются правильно. Это дизайн, который я использовал:

https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-dotnet-framework-getstarted-receive-eph

У меня проблема в том, что в концентраторе событий около 4 миллионов событий, и метод ProcessEventsAsync вызывается 4 или 5 раз, а затем перестает вызываться.

Есть ли способ, которым я могу просто запросить, чтобы получать только сообщения, добавленные за последние X минут?

Answer 1

Вместо того, чтобы использовать EventProcessorHostВы можете напрямую прочитать все события. Это означает, что вы позвоните Receiveметод непосредственно, чтобы прочитать пакет событий.

См. Прямые приемники событий приемника и шины служебной шины для получения примеров кода.

Нет возможности фильтровать события по времени (последние X секунд), смещения являются единственным адресуемым пространством.