Dotnet RateLimiter должен быть в состоянии вызвать асинхронную функцию ⇐ C#

[Anonymous]

Я использую microsoft.aspnetcore.ratelimiting и добавление новой политики, которая ограничивает, сколько вызовов может быть сделано в минуту для конкретного Apikey. Большинство ключей имеют одинаковый предел вызова, но некоторые ключи будут иметь больше или меньше, чем по умолчанию. Я хочу обновить код так, чтобы поиск ключа, чтобы увидеть, есть ли у него разные тарифы в асинхронной манере, но я продолжаю получать ошибки компиляции, когда добавляю асинхронное прозвище в фонд, который передается. Я. Я предполагаю, что это невозможно, но, возможно, есть другой способ сделать это?builder.Services.AddRateLimiter(options =>
{
options.OnRejected = async (context, cancellationToken) =>
{
if (context.Lease.TryGetMetadata(MetadataName.RetryAfter, out var retryAfter))
{
context.HttpContext.Response.Headers.RetryAfter =
((int)retryAfter.TotalSeconds).ToString(NumberFormatInfo.InvariantInfo);
}

context.HttpContext.Response.StatusCode = StatusCodes.Status429TooManyRequests;
await context.HttpContext.Response.WriteAsync("Too many requests for your Api Key. Please try again later.", cancellationToken);
};

options.AddPolicy("ApiKey_Minute", context =>
{
var keyService = context.RequestServices.GetRequiredService();
var apiKey = context.Request.Headers["X-Api-Key"].FirstOrDefault();
var defaultLimit = RateLimitPartition.GetTokenBucketLimiter("defaultLimit", _ =>
new TokenBucketRateLimiterOptions
{
TokenLimit = 5,
TokensPerPeriod = 5,
ReplenishmentPeriod = TimeSpan.FromMinutes(1),
QueueLimit = 0,
AutoReplenishment = true
}); ;
if(string.IsNullOrWhiteSpace(apiKey))
{
return defaultLimit;
}
//currently this is not async but ideally should be
var keyInfo = keyService.LookupKey(apiKey);
if(keyInfo == null)
{
return defaultLimit;
}
var perMinuteLimiter = RateLimitPartition.GetFixedWindowLimiter(
partitionKey: $"{apiKey}-minute",
factory: _ => new FixedWindowRateLimiterOptions
{
PermitLimit = keyInfo.CallsPerMinute ?? 5, //TODO update to 50
Window = TimeSpan.FromMinutes(1),
QueueProcessingOrder = QueueProcessingOrder.OldestFirst,
QueueLimit = 2
}
);

return perMinuteLimiter;
});


Подробнее здесь: https://stackoverflow.com/questions/794 ... c-function