Получение ошибки «Сообщение запроса уже отправлено» при использовании Polly ⇐ C#

[Anonymous]

В настоящее время я использую Polly, чтобы ограничить количество отправляемых запросов. Вот моя политика в настоящее время:

Код: Выделить всё

private AsyncPolicyWrap DefineAndRetrieveResiliencyStrategy()
{
HttpStatusCode[] retryCodes = {
HttpStatusCode.InternalServerError,
HttpStatusCode.BadGateway,
HttpStatusCode.GatewayTimeout
};

var waitAndRetryPolicy = Policy
.HandleResult(e => e.StatusCode == HttpStatusCode.ServiceUnavailable || e.StatusCode == (HttpStatusCode)429)
.WaitAndRetryAsync(10,
attempt => TimeSpan.FromSeconds(5), (exception, calculatedWaitDuration) =>
{
_log.Info($"Bitfinex API server is throttling our requests. Automatically delaying for {calculatedWaitDuration.TotalMilliseconds}ms");
}
);

var circuitBreakerPolicyForRecoverable = Policy
.Handle()
.OrResult(r => retryCodes.Contains(r.StatusCode))
.CircuitBreakerAsync(
handledEventsAllowedBeforeBreaking: 3,
durationOfBreak: TimeSpan.FromSeconds(3),
onBreak: (outcome, breakDelay) =>
{
_log.Info($"Polly Circuit Breaker logging: Breaking the circuit for {breakDelay.TotalMilliseconds}ms due to: {outcome.Exception?.Message ?? outcome.Result.StatusCode.ToString()}");

},
onReset: () => _log.Info("Polly Circuit Breaker logging: Call ok... closed the circuit again"),
onHalfOpen: () => _log.Info("Polly Circuit Breaker logging: Half-open: Next call is a trial")
);

return Policy.WrapAsync(waitAndRetryPolicy, circuitBreakerPolicyForRecoverable);
}

У меня есть следующий отправитель запроса:

Код: Выделить всё

private async Task SendRequest(GenericRequest request, string httpMethod, string publicKey, string privateKey)
{
var resiliencyStrategy = DefineAndRetrieveResiliencyStrategy();

using (var client = new HttpClient())
using (var httpRequest = new HttpRequestMessage(new HttpMethod(httpMethod), request.request))
{
string json = JsonConvert.SerializeObject(request);
string json64 = Convert.ToBase64String(Encoding.UTF8.GetBytes(json));
byte[] data = Encoding.UTF8.GetBytes(json64);

client.BaseAddress = new Uri(Properties.Settings.Default.BitfinexUri);

var hashMaker = new HMACSHA384(Encoding.UTF8.GetBytes(privateKey));
byte[] hash = hashMaker.ComputeHash(data);
string signature = GetHexString(hash);

httpRequest.Headers.Add("X-BFX-APIKEY", publicKey);
httpRequest.Headers.Add("X-BFX-PAYLOAD", json64);
httpRequest.Headers.Add("X-BFX-SIGNATURE", signature);

var message = await resiliencyStrategy.ExecuteAsync(() => client.SendAsync(httpRequest));
var response = message.Content.ReadAsStringAsync().Result;

return response;
}
}

Как только код достигает waitAndRetryPolicy и ожидает необходимое количество времени, я получаю следующую ошибку:

System.InvalidOperationException: 'Сообщение с запросом уже отправлено. Невозможно отправить одно и то же сообщение запроса несколько раз.

Я понимаю, что это происходит, потому что я снова отправляю один и тот же HttpRequest, но библиотека Polly не должна этого делать. справиться с такой проблемой?

Подробнее здесь: https://stackoverflow.com/questions/548 ... sing-polly