Axios 异步请求的条件式重试与状态检测

const axios = require("axios");
const qs = require("qs");

// 假设 apiKey 在当前作用域内可用，请替换为你的实际API密钥
const apiKey = "YOUR_DEEPL_API_KEY";

const initialConfig = {
    method: "post",
    maxBodyLength: Infinity, // 允许最大请求体长度
    url: "https://api-free.deepl.com/v2/document/95BA71197AC66EE4745FF5269CF4399D",
    headers: {
        Authorization: `DeepL-Auth-Key ${apiKey}`, // DeepL API 密钥通常这样传递
        "Content-Type": "application/x-www-form-urlencoded",
    },
    data: qs.stringify({
        document_key: "038A2E0792CE72020E9BB88380D002EB582A6B3AE5883C34DE53C9F17D415D99",
    }),
};

/**
 * 引入延迟的辅助函数
 * @param {number} ms - 延迟毫秒数
 */
const delay = (ms) => new Promise(resolve => setTimeout(resolve, ms));

/**
 * 重试 API 请求直到特定状态或达到最大重试次数
 * @param {object} config - Axios 请求配置
 * @param {string} targetStatus - 期望的响应状态值
 * @param {number} maxRetries - 最大重试次数
 * @param {number} initialDelayMs - 初始重试延迟（毫秒）
 * @returns {Promise<any>} - 成功时的响应数据
 * @throws {Error} - 如果重试失败或达到最大重试次数
 */
async function retryApiRequestUntilStatus(
    config,
    targetStatus,
    maxRetries = 5,
    initialDelayMs = 1000
) {
    let attempts = 0;
    let currentDelay = initialDelayMs; // 当前延迟时间，用于指数退避

    while (attempts < maxRetries) {
        attempts++;
        try {
            console.log(`尝试发起请求 (第 ${attempts} 次)...`);
            const response = await axios.request(config);
            const status = response.data.status;

            if (status === targetStatus) {
                console.log(`请求成功，状态为 "${targetStatus}"。`);
                return response.data; // 返回完整的响应数据
            } else {
                console.log(`当前状态为 "${status}"，不符合预期 "${targetStatus}"。`);
                if (attempts < maxRetries) {
                    console.log(`等待 ${currentDelay / 1000} 秒后重试...`);
                    await delay(currentDelay);
                    // 实现指数退避：每次重试失败后增加延迟时间
                    currentDelay = Math.min(currentDelay * 2, 60000); // 最大延迟不超过60秒
                }
            }
        } catch (error) {
            console.error(`请求失败 (第 ${attempts} 次): ${error.message}`);
            if (attempts < maxRetries) {
                console.log(`等待 ${currentDelay / 1000} 秒后重试...`);
                await delay(currentDelay);
                currentDelay = Math.min(currentDelay * 2, 60000); // 最大延迟不超过60秒
            } else {
                // 达到最大重试次数后，抛出错误
                throw new Error(`API 请求在 ${maxRetries} 次尝试后仍未成功：${error.message}`);
            }
        }
    }
    // 循环结束，但未达到目标状态
    throw new Error(`API 请求在 ${maxRetries} 次尝试后仍未达到状态 "${targetStatus}"。`);
}

// 示例调用
(async () => {
    try {
        const result = await retryApiRequestUntilStatus(
            initialConfig,
            "done",      // 期望的目标状态
            10,          // 最大重试次数
            500          // 初始延迟 500 毫秒
        );
        console.log("最终结果:", result);
    } catch (error) {
        console.error("操作失败:", error.message);
    }
})();