javascript - 发布请求后,继续检查是否完成 | 节点.js
问题描述
我正在发出一个包含大量数据的发布请求,大约需要一分钟才能完成保存。我为此使用的托管服务将在 5 秒后超时请求,因此我需要设置它以定期检查数据保存是否完成以提供最终更新。
我正在使用request-promise
,并查看了setTimeout
和setInterval
方法。在我最近的尝试(如下)中,我使用了一种setTimeout
方法,但我的第二种方法then
几乎立即被调用。我希望它在第一then
阶段挂出,直到它被检查了很多次(这里是 24 次)或实际完成。
我在这里可能有一个完全错误的方法,但我没有找到我试图引用的东西的例子。任何指向一个很好的例子或我出错的地方都将不胜感激。
const request = require('request-promise');
function checkFiles () {
return request({
uri: `${process.env.ROOT_URL}/api/v1/get/file-processing`,
method: 'GET',
json: true
})
.then(res => { return res; })
.catch(err => { return err; });
}
async function init () {
const filesPostOptions = {/* request options */};
await request(filesPostOptions)
.then(async status => { // THEN #1
if (status.status === 201) {
return status;
}
let checks = 0;
const checkIt = function() {
checks++;
checkFiles()
.then(res => {
if (res.status === 201 || checks > 24) {
status = res;
return status;
} else {
setTimeout(checkIt, 5000);
}
})
.catch(err => {
console.error(err);
});
};
checkIt();
})
.then(status => { // THEN #2
if (!status.status) {
throw Error('Post request timed out.');
}
return status;
})
.catch(err => {
err = err.error ? err.error : err;
console.error(err);
});
}
发布响应将传递带有status
属性(状态代码)和message
属性的响应。
解决方案
您需要"THEN #"
通过添加一个来控制返回Promise
:
.then(async status => { // THEN #1
return new Promise((resolve, reject) => { // <---- prevent an immediate return
if (status.status === 201) {
return resolve(status);
}
let checks = 0;
const checkIt = function() {
checks++;
checkFiles()
.then(res => {
if (res.status === 201 || checks > 24) {
status = res;
resolve(status);
} else {
setTimeout(checkIt, 1000);
}
})
.catch(err => reject(err));
};
checkIt();
})
})
推荐阅读
- python - 如何为具有相同父元素的两个 python 列表的连接编写正确的类型
- java - Maven 部署到 2 个不同的远程存储库
- c++ - 在收据中显示所有用户的选择
- python - 没有名为“ebcli.core”的模块
- c# - 如何使用代码禁用 Windows 10 FPS 限制器?
- bootstrap-5 - bootstrap 5 工具提示闪烁一次然后消失
- backup - 使用 tar 从文件传输中排除(符号/硬)链接
- r - 如何在灵活表输出中打印数字符号以及其他要求?
- iis-7.5 - 来自应用程序的 Asp.net Web 不在 IIS 中运行
- javascript - 如何在 mongoDB 中将 2 个模式与 _id 连接