如何为 requests.post 实现健壮的重试机制与正确中断循环

response = requests.post(url, data, headers) # 这里的data和headers会被requests误解为files等其他参数

response = requests.post(url, data=data, headers=headers)

except (requests.exceptions.RequestException, Exception):
  print(f"Request failed with exception: {e}. Retrying...") # 这里的e未被定义

except (requests.exceptions.RequestException, Exception) as e:
  print(f"Request failed with exception: {e}. Retrying...")

import requests
import time # 引入time模块用于在重试之间进行等待

def retry_post(url: str, data: dict, headers: dict, max_retries: int = 3, delay_seconds: int = 2):
    """
    对 requests.post 请求实现健壮的重试机制。

    Args:
        url (str): 请求的目标URL。
        data (dict): 请求体数据，通常是字典形式。
        headers (dict): 请求头信息，通常是字典形式。
        max_retries (int): 最大重试次数。默认为3。
        delay_seconds (int): 每次重试之间的等待时间（秒）。默认为2。

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

    Raises:
        RuntimeError: 如果在达到最大重试次数后请求仍未成功。
    """
    response = None # 初始化response，以防循环未能成功执行一次请求
    for retry_attempt in range(max_retries):
        try:
            # 使用关键字参数传递data和headers
            print(f"尝试发送请求 (第 {retry_attempt + 1}/{max_retries} 次)...")
            response = requests.post(url, data=data, headers=headers)

            if response.status_code == 200:
                print("请求成功！")
                break  # 请求成功，跳出重试循环
            else:
                print(f"请求失败，状态码: {response.status_code}. 准备重试...")

        except requests.exceptions.RequestException as e:
            # 捕获requests库特定的异常
            print(f"请求发生网络或连接异常: {e}. 准备重试...")
        except Exception as e:
            # 捕获其他未知异常
            print(f"请求发生未知异常: {e}. 准备重试...")

        # 如果不是最后一次尝试，则等待一段时间再重试
        if retry_attempt < max_retries - 1:
            time.sleep(delay_seconds)
        else:
            print("已达到最大重试次数。")

    # 循环结束后，检查最终结果
    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", "number": 123}
    test_headers = {"Content-Type": "application/x-www-form-urlencoded"}

    try:
        # 模拟一个成功的请求
        print("\n--- 模拟成功请求 ---")
        successful_response = retry_post(test_url, test_data, test_headers, max_retries=3)
        print(f"最终响应状态码: {successful_response.status_code}")
        print(f"最终响应内容: {successful_response.json()}")

        # 模拟一个总是失败的请求 (例如，一个不存在的URL或者一个总是返回非200的URL)
        # 注意：httpbin.org/status/500 会返回500错误
        print("\n--- 模拟失败请求 ---")
        fail_url = "https://httpbin.org/status/500"
        failed_response = retry_post(fail_url, test_data, test_headers, max_retries=2, delay_seconds=1)
        # 这行代码不会被执行，因为会抛出RuntimeError
        print(f"最终响应状态码 (预期不会出现): {failed_response.status_code}") 
    except RuntimeError as e:
        print(f"捕获到运行时错误: {e}")
    except Exception as e:
        print(f"捕获到其他错误: {e}")

    # 模拟一个连接错误的请求 (例如，一个无法解析的域名)
    print("\n--- 模拟连接错误请求 ---")
    invalid_url = "http://nonexistent-domain-12345.com/post"
    try:
        retry_post(invalid_url, test_data, test_headers, max_retries=2, delay_seconds=1)
    except RuntimeError as e:
        print(f"捕获到运行时错误: {e}")
    except Exception as e:
        print(f"捕获到其他错误: {e}")