我正在发布一个包含大量数据的帖子请求,大约需要一分钟才能完成保存。我正在使用的托管服务将在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();
})
})