10

我正在使用一个非常不稳定的 API。有时我得到500 Server Error了Timeout，其他时候我也得到500 Server Error了，因为我给了它无法处理的输入SqlDateTime overflow. Must be between 1/1/1753 12:00:00 AM and 12/31/9999 11:59:59 PM.。

这两种情况都给了我HttpRequestException，但我可以查看来自服务器的回复消息并确定异常的原因。如果是超时错误，我应该再试一次。如果输入错误，我应该重新抛出异常，因为再多的重试都无法解决错误数据的问题。

我想对 Polly 做的是在尝试重试之前检查响应消息。但是到目前为止我看到的所有样本都只包含异常类型。

到目前为止，我已经想出了这个：

        HttpResponseMessage response = null;
        String stringContent = null;
        Policy.Handle<FlakyApiException>()
             .WaitAndRetry(5, retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)),
              async (exception, timeSpan, context) =>
            {
                response = await client.PostAsync(requestUri, new StringContent(serialisedParameters, Encoding.UTF8, "application/json"));
                stringContent = await response.Content.ReadAsStringAsync();

                if (response.StatusCode == HttpStatusCode.InternalServerError && stringContent.Contains("Timeout"))
                {
                    throw new FlakyApiException(stringContent);
                }
            });

有没有更好的方法来做这种检查？

4

1 回答 1

10

通常，您可以配置 Polly 策略以响应执行结果（不仅仅是异常），例如HttpResponseMessage.StatusCode使用谓词检查 an。Polly 自述文件中的示例。

但是，没有一种内置方法可以配置单个Polly 策略来额外响应响应消息的内容。这是因为（如您的示例所示）获取该内容需要第二次异步调用，这本身可能会引发网络错误。

这个tl;dr导致了如何表达（以简单的语法）单个策略的复杂性，该策略管理两个不同的异步步骤，每个步骤可能有不同的错误处理。之前在 Polly github 上的相关讨论：欢迎评论。

因此，如果一个序列需要两个单独的异步调用，Polly 团队目前建议将其表示为两个单独的策略，类似于本答案末尾的示例。

您问题中的特定示例可能不起作用，因为onRetryAsync委托（投掷FlakyApiException）本身不受策略保护。策略仅保护通过 执行的委托的执行.Execute/ExecuteAsync(...)。

一种方法是使用两种策略，一种重试策略，重试所有典型的 http 异常和状态码，包括 500；然后在其中一个 Polly FallbackPolicy，它捕获表示 500 的状态代码，并通过重新抛出一些可区分的异常 ( ) SqlDateTime overflow来排除该状态代码的重试。CustomSqlDateOverflowException

        IAsyncPolicy<HttpResponseMessage> rejectSqlError = Policy<HttpResponseMessage>
            .HandleResult(r => r.StatusCode == HttpStatusCode.InternalServerError)
            .FallbackAsync(async (delegateOutcome, context, token) =>
            {
                String stringContent = await delegateOutcome.Result.Content.ReadAsStringAsync(); // Could wrap this line in an additional policy as desired.
                if (delegateOutcome.Result.StatusCode == HttpStatusCode.InternalServerError && stringContent.Contains("SqlDateTime overflow"))
                {
                    throw new CustomSqlDateOverflowException(); // Replace 500 SqlDateTime overflow with something else.
                }
                else
                {
                    return delegateOutcome.Result; // render all other 500s as they were
                }
            }, async (delegateOutcome, context) => { /* log (if desired) that InternalServerError was checked for what kind */ });

        IAsyncPolicy<HttpResponseMessage> retryPolicy = Policy<HttpResponseMessage>
            .Handle<HttpRequestException>()
            .OrResult(r => r.StatusCode == HttpStatusCode.InternalServerError)
            .OrResult(r => /* condition for any other errors you want to handle */)
            .WaitAndRetry(5, retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)),
                async (exception, timeSpan, context) =>
                {
                    /* log (if desired) retry being invoked */
                });

        HttpResponseMessage response = await retryPolicy.WrapAsync(rejectSqlError)
            .ExecuteAsync(() => client.PostAsync(requestUri, new StringContent(serialisedParameters, Encoding.UTF8, "application/json"), cancellationToken));
于 2018-06-13T19:16:52.243 回答