如何在 Polly ExecuteAsync 的 lambda 表达式中包含多行代码块？

Question

我的工作代码使用 Polly 策略 (IAsyncPolicy<HttpResponseMessage>) 上的 ExecuteAsync() 方法从网页中提取数据。我想向它添加一些调试日志记录，但到目前为止，我无法弄清楚发生这种情况的正确语法，除非我将日志记录和 http 调用包装在一个单独的方法中，然后通过 @987654327 调用它@。

这对我来说似乎并不“正确”，我觉得有一种更清洁或更直接的方法。我认为我的问题是我对 Func<T> 和 lambda 表达式如何真正操作来实现这一点没有足够的了解，因为当我将内容包装在 {} 中时，我会遇到如下错误：

并非所有代码路径都返回 Func<CancellationToken, Task<HttpResponseMessage>> 类型的 lambda 表达式中的值。

这是我原来的工作代码：

var httpClient = _httpClientFactory.CreateClient();
HttpResponseMessage result;
var retryPolicy = (IAsyncPolicy<HttpResponseMessage>)_policyRegistry[RetryPolicyKeyName];

result = await retryPolicy.ExecuteAsync(
    async cancellationToken =>    
        await httpClient.GetAsync(myUrl, cancellationToken)
    , cancellationToken
);

此代码会产生“并非所有代码路径都在 Func<CancellationToken, Task> 类型的 lambda 表达式中返回值错误：

var httpClient = _httpClientFactory.CreateClient();
HttpResponseMessage result;
var retryPolicy = (IAsyncPolicy<HttpResponseMessage>)_policyRegistry[RetryPolicyKeyName];

result = await retryPolicy.ExecuteAsync(
    async cancellationToken =>    
    {
        await httpClient.GetAsync(myUrl, cancellationToken);
    }
    , cancellationToken
);

这是我的“hack”，可以通过额外的方法完成我想要的：

private async Task<HttpResponseMessage> TestWithLogAsync(HttpClient httpClient, string myUrl, CancellationToken cancellationToken)
{
    _logger.LogDebug("Requesting from: {myUrl}", myUrl);
    var result = await httpClient.GetAsync(myUrl, cancellationToken);
    return result;
}

var httpClient = _httpClientFactory.CreateClient();
HttpResponseMessage result;
var retryPolicy = (IAsyncPolicy<HttpResponseMessage>)_policyRegistry[RetryPolicyKeyName];

result = await retryPolicy.ExecuteAsync(
    async cancellationToken =>
        await TestWithLogAsync(httpClient, myUrl, cancellationToken)
    , cancellationToken
);

Answer 1

你有什么：

result = await retryPolicy.ExecuteAsync(
    await httpClient.GetAsync(managementUrl, cancellationToken)
    , cancellationToken
);

相当于：

result = await retryPolicy.ExecuteAsync(async () => {
      return await httpClient.GetAsync(managementUrl, cancellationToken);
    }
    , cancellationToken
);

因此这将在 lambda 中执行多行：

result = await retryPolicy.ExecuteAsync(async () => {
      _logger.LogDebug("Requesting from: {managementUrl}", managementUrl);
      return await httpClient.GetAsync(managementUrl, cancellationToken);
    }
    , cancellationToken
);

_{..虽然我不太清楚managementUrl 在您的示例中如何变成myUrl，以及它们是否不同.. 我假设不是}