Ошибки обработки SDK и очереди в Azure Webjobs

Question

Я работаю над webjob, который проверяет веб-сервер для некоторых данных. Иногда веб-сервер занят, и через несколько секунд он снова попытается повторить попытку.

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

Мое текущее решение (которое мне совсем не нравится) заключается в исключении, которое увеличит число dequque и вернет сообщение в очередь. Это, однако, кажется очень жестоким и требует потока, который работает webjob для перезапуска.

Есть ли другой способ обращения с этим?

Answer 1

Webjobs SDK будет запускать функции запуска очереди, если они генерируют исключение. Количество попыток настроено через свойство JobHostConfiguration.Queues.MaxDequeueCount, как описано here.

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

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

public static void WebJobFunction([QueueTrigger("temp")] string message) 
{ 
    int retriesLeft= 5; 

    while(true) 
    { 
     try 
     { 
      --retriesLeft; 
      DoServerOperation(message); 
      break; 

     } 
     catch(TimeoutException) 
     { 
      if (retriesLeft == 0) 
      { 
       throw; 
      } 
     }  
    } 
}