0

我是 Nodejs 新手,无法理解这个问题:我尝试对数组运行 describe 函数,而 AWS 函数似乎在 main 函数完成后运行。

这是主要功能:(遍历 ACM ARN 列表并检查状态)

var checkCertStatus = function(resolveObj){
    var promise = new Promise(function(resolve, reject){

        console.log('1');
        var retObj='';
        resolveObj.Items.forEach(function(element) {
            var certDescribeParams = {
                CertificateArn: element.sslCertId
            };
            console.log('2');
            acm.describeCertificate(certDescribeParams, function(err, data) {
                if(err) reject(new Error(err));
                else     {
                    console.log(data.Certificate.DomainName + ': ' + data.Certificate.Status);
                    retObj+=data;
                }
            });
        });
        console.log('3');
        resolve(retObj);
        return promise;
    })
}

根据调试日志,假设有 2 项需要处理,我得到的是:

1
2
2
3
example.com: ISSUED
example2.com: ISSUED

基本上,我需要将此结果传递给链中的下一个函数(带有承诺和东西)。

4

1 回答 1

1

欢迎使用 Node.js!一般来说,学习异步编程风格可能会有所帮助。特别是,您似乎混合了Promisescallbacks,这可能会使这个示例比它需要的更加混乱。我建议使用 AWS SDK 的内置功能将响应转换为 Promise。

我注意到的第一件事是您正在手动构造一个带有解析/拒绝功能的 Promise。除非您正在创建库,否则这通常是一个危险信号。大多数其他库都支持您可以简单地使用和链接的 Promises。(这包括 AWS 开发工具包,如上所述。)

我注意到的第二件事是你的checkCertStatus函数没有返回任何东西。它创建了一个 Promise,但最后没有返回它。您的return promise;行实际上是在用于创建 Promise 的回调函数内。

就个人而言,在使用 Promises 时,我更喜欢使用Bluebird库。它提供了比原生更全功能的 Promises,包括map等方法。方便的是,AWS SDK 可以通过此处AWS.config.setPromisesDependency()记录的方式配置为与替代的 Promise 构造函数一起使用。

为了简化您的逻辑,您可以尝试以下方式(未经测试的代码):

const Promise = require('bluebird');
AWS.config.setPromisesDependency(Promise);

const checkCertStatus = (resolveObj) => {
    const items = resolveObj.Items;
    console.log(`Mapping ${items.length} item(s)`);
    return Promise.resolve(items)
        .map((item) => {
            const certDescribeParams = {
                CertificateArn: item.sslCertId,
            };
            console.log(`Calling describeCertificate for ${item.sslCertId}`);
            return acm.describeCertificate(certDescribeParams)
                .promise()
                .then((data) => {
                    console.log(`${data.Certificate.DomainName}: ${data.Certificate.Status}`);
                    return data;
                });
        });
};

我们将定义checkCertStatus为一个函数,它接收resolveObj并返回一个从 开始的 Promise 链resolveObj.Items。(如果您还不熟悉箭头函数,我深表歉意。)此链中的第一步也是唯一的一步是将数组映射到从该方法items返回的新 Promises 数组。acm.describeCertificate如果这些单个 Promise 中的任何一个失败,顶级 Promise 链也将拒绝。否则,顶级 Promise 链将解析为结果数组。(请注意,我包含了一个无关紧要的.then步骤来记录单个结果,但您可以完全删除该子句。)

希望这会有所帮助,如果我在代码中留下任何错误,我深表歉意。

于 2017-11-21T19:19:47.917 回答