如何在AWS Lambda中正确使用HttpClient避免API请求超限

问题根因 #

• 当前static HttpClient的初始化逻辑本身是.NET Lambda的官方推荐实践，热启动复用属于正常设计，请求量超标的核心原因有两个：
  1. AWS Lambda会自动根据调用堆积、实例健康状态扩容实例数量，运行满1小时后可能存在多个存活的热实例同时响应触发请求，每个实例独立发起API调用，总请求量叠加后超出API A的限流阈值
  2. 未对单次Lambda执行的API调用做次数校验、异常重试控制，请求失败后的自动重试会进一步放大请求量

正确实现步骤 #

1. 保留HttpClient静态复用逻辑，补充连接生命周期配置 #

调整原初始化代码，避免旧连接异常导致的重复请求，同时适配Lambda实例的回收规则：

public static readonly HttpClient client = new HttpClient(new SocketsHttpHandler
{
    PooledConnectionLifetime = TimeSpan.FromMinutes(15),
    PooledConnectionIdleTimeout = TimeSpan.FromMinutes(5)
})
{
    Timeout = TimeSpan.FromSeconds(10)
};

静态初始化的位置不需要改动，仅补充内部配置即可解决长连接异常问题。

2. 增加客户端限流控制 #

调用API A前增加限流校验，建议单实例限流阈值设置为总限流值的1/10以内，预留足够冗余应对实例临时扩容的情况，参考实现：

// 类顶部声明静态限流组件
private static readonly SemaphoreSlim _rateLimiter = new SemaphoreSlim(10, 10);
private static DateTime _lastResetTime = DateTime.UtcNow;

// 调用API A前执行限流校验
lock(_lastResetTime)
{
    if (DateTime.UtcNow.Subtract(_lastResetTime).TotalMinutes >= 1)
    {
        _rateLimiter.Release(10 - _rateLimiter.CurrentCount);
        _lastResetTime = DateTime.UtcNow;
    }
}
await _rateLimiter.WaitAsync();
try
{
    // 此处写API A的请求逻辑
}
finally
{
    // 不需要主动释放，限流计数器每分钟自动重置
}

3. 调整Lambda配置避免多实例冗余触发 #

• 在Lambda控制台设置预留并发数为1，确保始终只有一个实例处理触发请求，不会出现多实例同时执行的情况
• 关闭Lambda默认的自动重试机制，避免执行失败时重复发起请求
• 配置函数超时时间小于1分钟，避免前一次执行未结束、后一次触发又启动导致的重复请求

4. 增加幂等校验避免重复执行 #

每次函数启动时先用请求ID做幂等判断，避免同一触发事件被重复处理：

// 类顶部声明静态幂等缓存
private static readonly HashSet<string> _processedEventIds = new HashSet<string>();
private static DateTime _cacheCleanTime = DateTime.UtcNow;

// 函数入口最靠前的位置执行幂等校验
public async Task FunctionHandler(ILambdaContext context)
{
    lock(_cacheCleanTime)
    {
        if (DateTime.UtcNow.Subtract(_cacheCleanTime).TotalHours > 1)
        {
            _processedEventIds.Clear();
            _cacheCleanTime = DateTime.UtcNow;
        }
    }
    if (_processedEventIds.Contains(context.AwsRequestId))
    {
        return;
    }
    _processedEventIds.Add(context.AwsRequestId);
    
    // 后续写业务逻辑
}

内容的提问来源于stack exchange，提问作者Yusuf_M