Bluebird Promise 重试 DocumentDB 请求

Question

我正在尝试将带有回调的重试函数重写为 Bluebird promise 函数，但似乎无法理解执行此操作的正确方法。底部是工作回调函数，用于在达到限制时重试 Azure DocumentDB。我正在尝试在函数本身中使用 promises 但它在到达 "Then" 之前 returns。任何有关如何解决此问题或以这种方式使用 catch 是否会影响性能的提示都将不胜感激。谢谢！

"readDocRetry": function(id, retries) {
                var self = this;
                return new Promise(function(resolve, reject){
                    self.client.readDocumentAsync(self.docsLink + id, null, function(err, data){
                        if (err) {
                            reject(err);
                        } else {
                            resolve(data)
                        }
                    }).then(function(results) {
                        console.log("ReadDocRetry result: " + results)
                         return results;
                    }).catch(function(err, headers) {
                        RetryError(self, id, err, headers, retries);
                    });

                });
            }

function RetryError(self, id, err, headers, retries) {
    if (err && err.code) {
        if (err.code === 429 && retries >= 0) {
            setTimeout(function() {
                self.readDocRetry(id, retries - 1); 
            }, Number(headers['x-ms-retry-after-ms'] || 1));
        }
        else if (err.code === 503 && retries >= 0) {
            setTimeout(function() {
                self.readDocRetry(id, retries - 1) 
            }, 500); 
        }
    }
    else if(err) {
        console.log(err); 
    }else{
        console.log("Err missing in RetryError");
    }
}


    bbCtx.readDocRetry("19").then(function(res){
        console.log("Hurrah!" + res);
    })

-------- 传统回调的工作示例，我试图基于 promise -----

    dbContext.prototype = {
        readDocRetry: function (id, retries, cb) {
            var self = this;
            self.client.readDocument(self.docsLink + id, function (err, results, headers) {
                if (err) {
                    if (err.code === 429 && retries >= 0) {
                        var aR = retries - 1;
                        setTimeout(function () {
                                self.readDocRetry(id, aR, cb);
                        }, Number(headers['x-ms-retry-after-ms'] || 1));
                    } else if (err && err.code === 503 && retries >= 0) {
                        var aR = retries - 1;
                        setTimeout(function () {
                                self.readDocRetry(id, aR, cb)
                        }, 500); 
                    } else {
                        cb(err); 
                    }
                } else {
                    cb(null, results);
                }
            });
        },

Answer 1

当您的 catch 回调应该处理任何事情时，它需要 return 像所有其他承诺回调一样的新结果。在您的情况下，它可以 return 重试结果的承诺：

function readDocRetry(id, retries) {
    var self = this;
    return new Promise(function(resolve, reject){
        self.client.readDocumentAsync(self.docsLink + id, null, function(err, data){
            if (err) {
                reject(err);
            } else {
                resolve(data)
            }
        });
    }).then(function(results) {
        console.log("ReadDocRetry result: " + results)
        return results;
    }).catch(function(err, headers) {
        if (err && err.code) {
            if (err.code === 429 && retries >= 0) {
                return Promise.delay(headers['x-ms-retry-after-ms'] || 1).then(function() {
                    return self.readDocRetry(id, retries - 1); 
                });
            } else if (err.code === 503 && retries >= 0) {
                return Promise.delay(500).then(function() {
                    return self.readDocRetry(id, retries - 1) 
                });
            }
        }
        if (err) {
            console.log(err);
            throw err;
        } else {
            console.log("Err missing in RetryError");
            throw new Error("rejection without error");
        }
    });
}

Bluebird Promise 重试 DocumentDB 请求

Bluebird Promise Retry DocumentDB request

javascript

performance

promise

bluebird

azure-cosmosdb