HarmonyOS 鸿蒙Next 6怎么处理扣子工作流执行超时？

鸿蒙 6 处理扣子工作流超时，核心是请求加超时限制 + 有限重试（3 次内）+ 异步轮询结果（避免同步等待超时），代码极简且容错性强，适配偶尔超时的场景：

核心代码（超时重试 + 结果轮询）

import http from '@ohos.net.http';

// 配置项（按需修改）
const WORKFLOW_CONFIG = {
  url: 'https://www.kuaishou.com/openapi/v1/workflow/run',
  resultUrl: 'https://www.kuaishou.com/openapi/v1/workflow/result', // 查结果接口
  token: '你的工作流token',
  workflowId: '你的工作流ID',
  retryTimes: 3, // 最多重试3次
  pollInterval: 2000, // 轮询间隔2秒
  requestTimeout: 10000 // 单次请求超时10秒
};

// 1. 调用工作流（带超时+重试）
async callWorkflowWithRetry(params, retry = WORKFLOW_CONFIG.retryTimes) {
  const httpClient = http.createHttp();
  try {
    const res = await httpClient.request(WORKFLOW_CONFIG.url, {
      method: http.RequestMethod.POST,
      header: {
        'Content-Type': 'application/json',
        'Authorization': `Bearer ${WORKFLOW_CONFIG.token}`
      },
      extraData: JSON.stringify({
        workflow_id: WORKFLOW_CONFIG.workflowId,
        input: params,
        sync: false // 设为异步，避免同步等待超时
      }),
      readTimeout: WORKFLOW_CONFIG.requestTimeout, // 读取超时
      connectTimeout: WORKFLOW_CONFIG.requestTimeout // 连接超时
    });

    const data = JSON.parse(new TextDecoder().decode(res.result));
    if (data.code === 0 && data.data?.task_id) {
      // 2. 异步轮询工作流结果
      return await this.pollWorkflowResult(data.data.task_id);
    }
    return data;
  } catch (err) {
    // 超时/失败则重试（剩余次数>0时）
    if (retry > 0 && (err.message.includes('timeout') || err.message.includes('408'))) {
      console.log(`超时，剩余重试次数：${retry-1}`);
      await new Promise(resolve => setTimeout(resolve, 1000 * (WORKFLOW_CONFIG.retryTimes - retry + 1))); // 重试间隔递增
      return this.callWorkflowWithRetry(params, retry - 1);
    }
    throw new Error(`最终失败：${err.message}`);
  } finally {
    httpClient.destroy();
  }
}

// 2. 轮询工作流结果（直到成功/失败/超时）
async pollWorkflowResult(taskId, pollCount = 10) {
  if (pollCount <= 0) throw new Error('轮询超时');
  
  const httpClient = http.createHttp();
  try {
    const res = await httpClient.request(`${WORKFLOW_CONFIG.resultUrl}?task_id=${taskId}`, {
      method: http.RequestMethod.GET,
      header: { 'Authorization': `Bearer ${WORKFLOW_CONFIG.token}` }
    });

    const data = JSON.parse(new TextDecoder().decode(res.result));
    if (data.data?.status === 'success') {
      return data.data.output; // 返回最终结果
    } else if (data.data?.status === 'failed') {
      throw new Error(`工作流执行失败：${data.data.error_msg}`);
    } else {
      // 未完成则等待后继续轮询
      await new Promise(resolve => setTimeout(resolve, WORKFLOW_CONFIG.pollInterval));
      return this.pollWorkflowResult(taskId, pollCount - 1);
    }
  } finally {
    httpClient.destroy();
  }
}

// 调用示例
// this.callWorkflowWithRetry({ name: '测试参数' }).then(res => console.log('结果：', res));

关键说明：

1. 超时控制：给 HTTP 请求设readTimeout/connectTimeout（10 秒），直接拦截超时请求；
2. 有限重试：最多重试 3 次，且重试间隔递增（1s→2s→3s），避免频繁请求触发限流；
3. 异步轮询：工作流设为异步（sync: false），先拿task_id，再轮询查结果（最多轮询 10 次，约 20 秒），避免同步等待超时。

避坑点：

1. 重试次数不宜过多（3 次以内），否则易触发扣子平台频率限制；
2. 轮询间隔≥2 秒，过短会增加接口压力，建议根据工作流执行耗时调整；
3. 若工作流需同步执行，仅保留 “请求超时 + 重试” 逻辑即可，无需轮询。