并发、限流与重试

import time, requests

def create_with_retry(session, url, headers, body, max_retries=5):
    delay = 2
    for attempt in range(max_retries):
        resp = session.post(url, headers=headers, json=body)
        if resp.status_code < 400:
            return resp.json()
        # 仅对 429 / 5xx 退避重试；4xx 直接抛出
        if resp.status_code == 429 or resp.status_code >= 500:
            time.sleep(delay)
            delay *= 2
            continue
        resp.raise_for_status()
    raise RuntimeError("重试多次仍失败，请稍后再试")