Python requests 库重试机制深度解析：参数传递与异常处理实践

import requests

def retry_post_incorrect_params(url, data, headers, max_retries=3):
    for retry in range(max_retries):
        try:
            # 错误：data 和 headers 被作为位置参数传递
            response = requests.post(url, data, headers)
            if response.status_code == 200:
                print(f"Request successful on retry {retry + 1}")
                break # 预期在此处停止，但可能不工作
            else:
                print(f"Request failed with status code {response.status_code}. Retrying...")
        except (requests.exceptions.RequestException, Exception):
            print(f"Request failed with an unknown exception. Retrying...")
    # ... 后续处理

# 正确：data 和 headers 作为关键字参数传递
response = requests.post(url, data=data, headers=headers)

# ... 在 try 块中 ...
        except (requests.exceptions.RequestException, Exception):
            # 错误：e 未在此作用域内定义
            print(f"Request failed with exception: {e}. Retrying...")

        except (requests.exceptions.RequestException, Exception) as e:
            # 正确：e 现在是捕获到的异常对象
            print(f"Request failed with exception: {e}. Retrying...")

import requests
import time # 引入 time 模块用于添加延时

def retry_post(url, data, headers, max_retries=3):
    """
    尝试多次发送 POST 请求，直到成功或达到最大重试次数。

    Args:
        url (str): 请求的 URL。
        data (dict/str): 请求体数据。
        headers (dict): 请求头。
        max_retries (int): 最大重试次数。

    Returns:
        requests.Response: 成功的响应对象。

    Raises:
        RuntimeError: 如果达到最大重试次数后请求仍未成功。
    """
    response = None # 初始化 response，以防所有重试都失败
    for retry_count in range(max_retries):
        try:
            # 核心修正：正确传递 data 和 headers 作为关键字参数
            response = requests.post(url, data=data, headers=headers)

            if response.status_code == 200:
                print(f"请求成功！在第 {retry_count + 1} 次尝试。")
                break # 请求成功，跳出循环
            else:
                print(f"请求失败，状态码 {response.status_code}。正在重试 ({retry_count + 1}/{max_retries})...")
                # 考虑添加指数退避延时
                time.sleep(2 ** retry_count) # 第一次延时 1s, 第二次 2s, 第三次 4s
        except requests.exceptions.RequestException as e:
            # 核心修正：正确捕获异常并绑定到变量 e
            print(f"请求发生网络异常: {e}。正在重试 ({retry_count + 1}/{max_retries})...")
            time.sleep(2 ** retry_count) # 发生异常也延时
        except Exception as e:
            # 捕获其他未知异常
            print(f"请求发生未知异常: {e}。正在重试 ({retry_count + 1}/{max_retries})...")
            time.sleep(2 ** retry_count)

    # 循环结束后检查是否成功
    if response is None or response.status_code != 200:
        raise RuntimeError(f"达到最大重试次数 {max_retries}，请求仍未成功。")

    return response

# 示例使用
if __name__ == "__main__":
    test_url = "https://httpbin.org/post" # 一个用于测试 POST 请求的公共服务
    test_data = {"key": "value", "message": "Hello from retry function!"}
    test_headers = {"Content-Type": "application/x-www-form-urlencoded"}

    print("--- 尝试成功请求 ---")
    try:
        successful_response = retry_post(test_url, test_data, test_headers, max_retries=3)
        print(f"最终响应状态码: {successful_response.status_code}")
        print(f"最终响应内容: {successful_response.json()}")
    except RuntimeError as e:
        print(f"请求失败: {e}")

    # 模拟一个总是失败的请求 (例如，故意发送错误数据到不期望的端点)
    print("\n--- 尝试失败请求 (模拟) ---")
    # 为了模拟失败，我们可以尝试一个不存在的URL或者期望错误状态码
    # 这里我们仍然用 httpbin.org/post，但假定它会失败 (实际不会)
    # 实际测试中，您可能需要一个会返回非200状态码的端点
    try:
        # 为了演示，我们可以修改 max_retries 为 1 并且让它模拟失败
        # 或者指向一个会返回错误码的URL
        failed_response = retry_post("https://httpbin.org/status/500", test_data, test_headers, max_retries=3)
        print(f"最终响应状态码: {failed_response.status_code}")
    except RuntimeError as e:
        print(f"请求失败: {e}")