保持每 2.5 秒调用一次 API，并在达到所需结果后关闭调用

Question

我有一个 API 每 2.5 秒调用一次。最初，响应对象中的数据为空，因为数据库仍在通过事务对其进行更新。但在随后的第 3 次或第 4 次尝试中，我得到了数据。我正在为此编写一个可重用的函数，但是我没有定义。我的目标是继续调用 API，直到我获得路径中的值并关闭连接。请指教。

P.S：下面的 API URL 没有任何延迟，但我的私有 API 有。

const getData = (url, path) => {
  const interval = setInterval(async () => {
    const result = await axios.get(url);
    if (_.has(result.data, path) && result.data[path]) {
      return result[path]
    }
  }, 2500)
  return clearInterval(interval)
}

getData('https://api.oceandrivers.com/static/resources.json', 'swaggerVersion')

<script src="https://cdnjs.cloudflare.com/ajax/libs/lodash.js/4.17.15/lodash.js"></script>

JS Fiddle URL

请指教。

Answer 1

你

return clearInterval(interval); // undefined

如果你想返回一个在数据可用时解决的 Promise，你可以这样做：

const getData = (url, path) => {
  return new Promise((resolve, reject) => {
    const interval = setInterval(async() => {
      const result = await axios.get(url);
      if (_.has(result.data, path) && result.data[path]) {
        clearInterval(interval); // Clear the interval
        resolve(result.data[path]); // Resolve with the data
      }
    }, 2500);
  });
}

getData('https://api.oceandrivers.com/static/resources.json', 'swaggerVersion')
  .then(data => {
    console.log(data); // Your data is available here
  });

// OR

(async () => {
  const version = await getData('https://api.oceandrivers.com/static/resources.json', 'swaggerVersion');
  console.log(version);
})();

Answer 2

这是因为 javascript 是异步的，因为上面的评论已经提到过。您可以在 javascript 中使用回调或承诺。代码如下：

const getData = (url, path, cb) => {
  const interval = setInterval(async () => {
    const result = await axios.get(url);
    if (_.has(result.data, path) && result.data[path]) {
     clearInterval(interval); //We found it remove the interval
      cb(result.data[path]);
    }
  }, 2500);
};

getData(
  "https://api.oceandrivers.com/static/resources.json",
  "swaggerVersion",
  data => {
    console.log("test",data);
  }
);

这里是小提琴：https://jsfiddle.net/7pc4hq6t/3/

Answer 3

你可以创建一个异步延迟：

const delay = milliseconds => new Promise(resolve, setTimeout(resolve, milliseconds));

然后像这样使用：

const getDataAsync = async (url, path) => {
    while (true) {
        const result = await axios.get(url);
        if (_.has(result.data, path) && result.data[path]) {
            return result.data[path];
        }
        await delay(2500);
    }
}

const data = await getDataAsync('https://api.oceandrivers.com/static/resources.json', 'swaggerVersion');

这避免了多层嵌套回调，并生成更易读的代码。