如何强制节点等待 aws 承诺解析



尝试从节点访问 S3 存储桶.js快速应用程序。我正在尝试以 JSON 对象的形式从存储桶返回 JSON 文件。代码如下:

    let gets3 = function(file) {
        devs3();
        return new Promise(function(resolve, reject)  {
            var params = {
                Bucket: S3_BUCKET,
                Key: file
            }
            var s3 = new aws.S3();
            try {
            s3.getObject(params, function(err, data) {
                var myfile = JSON.parse(data.Body.toString());
                resolve(myfile);
            });
            } catch (err) {
                reject(err);
            }
        });
    }

module.exports = {

    fetchEvents : function(cata) {
        var myJson;
        switch (cata) {
            case "Pr":
                myJson = 'primaryEvents.json';
            case "Sc":
                myJson = 'secondaryEvents.json';
            case "Po":
                myJson = 'postEvents.json';
        }
        let gets3init = gets3(myJson);
        gets3init.then(function(file) {
            console.log('From Fetch Events: ' + JSON.stringify(file));
            return file;
        });
    }
}

devs3(( 只是设置 S3 登录信息并运行 aws.config.setPromisesDependancy。在我的主应用程序中.js,我运行fetchEvents("Pr"(,然后尝试显示它。在我的控制台中,它成功显示了 json 文件的内容,但是应用程序存在,但存在类型错误:cannot read property 'n' of undefined ,其中 n 是 Json 文件中第一个元素的名称。需要注意的一点是,此错误在打印 JSON 文件之前显示在控制台中,从而表明函数没有等待 gets3 完成并返回文件。是否有任何强制应用程序等待(这发生在页面加载时(以解决承诺?

感谢@Bergi为我指出正确的方向并帮助我得到这个答案。从本质上讲,我从一开始就错误地使用了承诺。我需要从 fetchEvents 函数返回承诺,而不是数据,然后在调用代码中使用它,以便仅在解决承诺后继续。
获取事件

module.exports = {

    fetchEvents : function(cata) {
        var myJson;
        switch (cata) {
            case "Pr":
                myJson = 'primaryEvents.json';
                break;
            case "Sc":
                myJson = 'secondaryEvents.json';
                break;
            case "Po":
                myJson = 'postEvents.json';
                break;
        }
        return gets3(myJson);
    }
}

呼叫代码

app.get('/PrEvents', function(req, res) {
    var myCata = req.path.replace('Events', '').replace('/', '');
    fetch(myCata).then(function(events) {
      res.render('pages/eventsShowTemp', {
        console.log(events);
      });
    });
  });

最新更新