如何在补丁化Boto客户端中触发限流拒绝请求并触发自动重试

要让Boto3客户端在限流时自动触发自身重试机制，你需要把限流检查逻辑补丁到**endpoint._send_request方法，其次是endpoint._get_response**，不建议选_do_get_response，原因如下：

核心原因：重试逻辑的触发范围 #

Boto3的重试逻辑是在endpoint._send_request方法中启动的——它会捕获请求过程中抛出的特定异常（比如含429状态码的ClientError），并根据配置的重试规则判断是否重试。而你之前在BaseClient._make_api_call中抛异常，还没进入重试逻辑的覆盖范围，自然不会触发重试。

优先选择endpoint._send_request的理由 #

1. 处于重试逻辑的入口：这个方法是Boto3发起请求、处理重试的核心入口，在这里插入限流拦截，抛出的429错误会被原生重试逻辑直接识别。
2. 无需绕过内部处理：它已经封装了请求前的准备工作，你只需要在原方法执行前加入限流检查，不影响Boto3的正常流程。

具体实现示例（Monkey Patch） #

import botocore.endpoint
from botocore.exceptions import ClientError

# 保存原方法引用
original_send_request = botocore.endpoint.Endpoint._send_request

def patched_send_request(self, request_dict, operation_model):
    # 执行你的限流检查逻辑
    if raise_429_if_rate_limit_reached():
        # 构造符合Boto3重试规则的429错误
        error_resp = {
            "Error": {
                "Code": "TooManyRequestsException",
                "Message": "Rate limit exceeded by stub"
            },
            "ResponseMetadata": {"HTTPStatusCode": 429}
        }
        raise ClientError(error_resp, operation_model.name)
    
    # 正常执行原请求逻辑
    return original_send_request(self, request_dict, operation_model)

# 替换原方法
botocore.endpoint.Endpoint._send_request = patched_send_request

为什么不选_do_get_response？ #

_do_get_response是底层发送HTTP请求的方法，属于重试逻辑的下游。在这里拦截的话，可能会绕开Boto3对请求的一些预处理（比如签名、参数校验），而且不如_send_request直接对接重试触发逻辑。

注意事项 #

• 确保你的限流检查逻辑是线程安全的，适配Boto3多线程使用场景。
• 错误码要匹配Boto3默认重试的规则（比如TooManyRequestsException或HTTP 429），如果是自定义错误码，需要修改Boto3的重试配置。

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