Функция Azure - EventHubTrigger и воспроизведение сообщений - PullRequest
0 голосов
/ 25 сентября 2019

Мне интересно, есть ли способ обновить текущее значение Offset, SequenceNumber или EnqueuedTimeUtc, с которого начинает считывать EventHubTrigger.

Я не использую захват Eventhub.Но допустим, что срок хранения сообщения составляет 7 дней, и функция в настоящее время обработала все сообщения.Могу ли я обновить группу потребителей, чтобы она воспроизводила все сообщения (из всех разделов), начиная с любого заданного времени за последние 7 дней?

Можно ли так же быстро переадресовать группу потребителей, которая в данный момент находится в процессе обработки, чтобы не обрабатывать сообщения раньше определенного времени?

Я не вижу ни одного хоста.Опции json или входные привязки для этого.

Возможно ли это только с помощью EventProcessorHost, а не привязки EventHubTrigger?

Вот упрощенная версия функции.


[FunctionName("ProcessEvents")]
public async Task ProcessEvents([EventHubTrigger("%EventHub-Name%", Connection = "EventHub-Connection", ConsumerGroup = "%EventHub-Consumer%")] EventData[] events, ILogger log)
{
     var exceptions = new List<Exception>();

     foreach (EventData eventData in events)
     {                
          try
          {
                await DoSomethingWithEvent(eventData);
          }
          catch (Exception e)
          {
                exceptions.Add(e);
                await DoSomethingWithError(e);
          }
      }

      if (exceptions.Count > 1)
          throw new AggregateException(exceptions);

      if (exceptions.Count == 1)
          throw exceptions.Single();
}

Спасибо!

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...