带有 settimeout 的异步 javascript 承诺调用

Question

我正在努力实现以下目标：

我要调用 3 个 API 来检索 DATA：

• 第一个 API 启动一个用于检索数据的作业并为其返回一个 id
• 第二个 API 通知我作业的状态（已完成、已取消...），我需要对该 API 执行多次调用，然后才能调用下一个。
• 第三个 API 是在作业完成时将数据发回给我的 API。

我遇到的问题是使用第二个 API，我没有成功将数据发送回我的程序，这是我的代码：

function getJobId(token) {
  return  $.ajax({
    url:  "url" + token;
  });
}

function getJobStatus(job_id) {
  var url = "url" + job_id;
  return  $.ajax({
    url: url
  });
}

getJobStatus(job_id).then(function(response) {
  if (response.jobrun_status === "QUEUED" || response.jobrun_status === "INPROGRESS") {
    //setTimeout(recursiveJobIdCheck(job_id), 2000);
    recursiveJobIdCheck(job_id);
  } else {
    console.log(response.jobrun_status);
    return response.jobrun_status;
  }
});

我确实尝试在对第二个 API 的每次调用之间设置一个超时，但没有成功，有人可以向我解释如何实现这一点，同时在每次请求调用之间保持间隔直到作业完成。

提前谢谢你。

编辑：我忘了在这里添加 recursiveJobIdCheck 函数

function recursiveJobIdCheck2(job_id) {
  return new Promise((resolve,reject) => {
    getJobStatus(job_id).then(function(response){
      if(response.jobrun_status === "QUEUED" || response.jobrun_status === "INPROGRESS"){
        //setTimeout(recursiveJobIdCheck(job_id), 2000);
        recursiveJobIdCheck2(job_id);
      }
      else{
        if(response.jobrun_status === "COMPLETED"){
        console.log(response.jobrun_status);
         resolve(response.jobrun_status);
         }
         else{
           reject(response.jobrun_status);
         }
      }
    });
  });
}

对 api 的调用在完成之前一直在运行，当我通过 Resolve 函数返回值时，.then 块内的主程序中没有任何反应

Answer 1

您将需要async/await 来处理递归 api 调用以简化代码。

function getJobStatus(job_id){
  var url = "url" + job_id;
  return  $.ajax({
    url : url
  });
}

function queueNextCall () {
  return new Promise(function (resolve, reject) {
    setTimeout(resolve, 2000);
  });
}

async function recursiveJobIdCheck(job_id) {
  var response = await getJobStatus(job_id)
  if(response.jobrun_status === "QUEUED" || response.jobrun_status === "INPROGRESS"){
    await queueNextCall();
    return recursiveJobIdCheck(job_id)
  } else {
    console.log(response.jobrun_status);
    return response.jobrun_status;
  }
}

而你所要做的就是打电话

recursiveJobIdCheck(job_id).then(/* Success job function */)