WebJobs不重试失败的队列消息

Question

我在使用新的0.3.0-beta版WebJobs SDK的WebJob中有以下逻辑。当我的代码处理消息失败时，Azure仪表板将显示聚合异常（这是有意义的，因为这是异步的）。但是，它不会重试处理消息。

我能找到的非常小的留档表明消息应该在失败后10分钟内重试。新的SDK不是这样吗？

public static Task ProcessMyMessageAsync(
    [QueueTrigger(Config.MY_QUEUE)] string msg, 
    int dequeueCount, 
    CancellationToken cancellationToken)
{
    var processor = Config.Container.GetInstance<IMessageProcessor>();
    return processor.HandleJobAsync(msg, dequeueCount, cancellationToken);
}

我得到的异常源于SQL超时异常（在我的代码中是针对SQL Azure的db查询）：

System.AggregateException: System.AggregateException: One or more errors occurred. 
    ---> System.Data.Entity.Core.EntityCommandExecutionException: An error occurred while executing  the command definition. See the inner exception for details. 
        ---> System.Data.SqlClient.SqlException: Timeout expired.  The timeout period elapsed prior to completion of the operation or the server is not responding. 
        ---> System.ComponentModel.Win32Exception: The wait operation timed out

Answer 1

您应该设置MaxDequeueCount。

JobHostConfiguration jobHostConf = new JobHostConfiguration();
jobHostConf.Queues.MaxDequeueCount = 10;
var host = new JobHost(jobHostConf);
host.RunAndBlock();

这将重试10次，在消息被放入死/坏信件队列之前。

还可以在函数中使用自定义重试策略。我建议你看看瞬态故障处理应用程序块https://msdn.microsoft.com/en-us/library/hh680934（v=pandp.50）. aspx

或者您可以在EF中启用重试，使用SqlAzureExecttionStrategyhttps://msdn.microsoft.com/en-us/data/dn456835.aspx