javascript - 将 Promise 嵌入 Promise 中

Question

我对 node.js 和 Promise 功能都很陌生，所以如果这个问题真的很愚蠢，请原谅我。

我正在尝试让子级 Promise 调用父级调用中的 forEach 子级(如果有意义的话)。

这是我的代码:

        return new Promise(function(resolve, reject) {
            var authorMapArray = new Array
            db.sequelize.query(authorQuery, {
                replacements: queryParams
            }).spread(function(authorSitemap) {
                authorSitemap.forEach(function(obj) {
                    /*
                    return new Promise (function(resolve, reject){
                        var thisQuery = photoQuery + ' AND author = ' + obj.id.toString();
                        db.sequelize.query(thisQuery, {
                            queryParams
                        }).spread(function(authorImages) {
                            var authorImageArray = new Array;
                            authorImages.forEach(function(obj) {
                                var imgLink = { url: imgHost + obj.img_id + '.jpg', title : img_tags }
                                authorImageArray.push(imgLink);
                            })
                        });
                        resolve(authorImageArray);
                    });
                    */
                    var authorLink = { url: 'author/' + obj.id, /*img: authorImageArray,*/ changefreq: 'weekly', priority: 0.6, lastmodrealtime: true }
                    siteMapArray.push(authorLink);
                });
                resolve(siteMapArray);

                //and finally create it
                createSiteMap(siteMapArray);
            });
        })

您会注意到，中间的部分已被注释掉。当我运行这样的代码时，我得到了我期望的结果，即添加到站点地图中的authorLink。当我取消注释代码(为了在站点地图中包含与作者关联的图像)时，甚至没有添加作者链接。

如何获取作者记录中包含的图像？

编辑

这是更完整的代码:

function createSiteMap(myURLs) {
    var rows = 10000;
    var totalMaps = Math.trunc(myURLs.length/rows)+1;
    var today = new Date();
    var mySitemaps = new Array;
    for (var i=1; i<totalMaps+1; i++) {
        var filename = "public/sitemap-" + i.toString() + ".xml";
        var sitemap = sm.createSitemap({
            hostname: hostname,
            cacheTime: 600000,  //600 sec (10 min) cache purge period 
            urls: myURLs.slice((i-1)*rows,i*rows)
            });
        fs.writeFileSync(filename, sitemap.toString());
        mySitemaps.push(filename);
    }

    // this needs to create sitemap tags not url tags
    var smi = sm.buildSitemapIndex({
        urls: mySitemaps
        });
    fs.writeFileSync("public/sitemap.xml", smi.toString());

    process.exit();
}

function uniq(a) {
    var seen = {};
    return a.filter(function(item) {
        return seen.hasOwnProperty(item) ? false : (seen[item] = true);
    });
}

function getPhotos() {
    return new Promise(function(resolve, reject) {
        var siteMapArray = new Array()        
        var tags = new Array()
        siteMapArray.push ({ url: '/' , changefreq: 'weekly', priority: 0.8, lastmodrealtime: true, lastmodfile: 'views/home.hbs' },)
        db.sequelize.query(photoQuery, {
            replacements: queryParams
        }).spread(function(makeSiteMap) {
            makeSiteMap.forEach(function(obj) {
                // images for sitemap
                var img_tags = obj.tags.replace(/,/g , " ");
                var imgLink = { url: imgHost + obj.img_id + '.jpg', title : img_tags }
                var siteLink = { url: 'photo/' + obj.img_id, img: imgLink, changefreq: 'weekly', priority: 0.6, lastmodrealtime: true }
                siteMapArray.push(siteLink);
                obj.tags = obj.tags.split(',').map(function(e) {
                    return e.trim().split(' ').join('+');
                });
                for (var tag in obj.tags) {
                    tags.push(obj.tags[tag])
                }
            });

            resolve (siteMapArray);

            //tags for sitemap
            var uniqueTags = uniq(tags);
            for (var tag in uniqueTags) {
                var siteLink = { url: '/search/' + uniqueTags[tag], changefreq: 'weekly', priority: 0.8, lastmodrealtime: true }
                siteMapArray.push (siteLink);
            }

            //now author tags
            return new Promise(function(resolve, reject) {
                var authorMapArray = new Array
                db.sequelize.query(authorQuery, {
                    replacements: queryParams
                }).spread(function(authorSitemap) {
                    authorSitemap.forEach(function(obj) {
                        /*
                        return new Promise (function(resolve, reject){
                            var thisQuery = photoQuery + ' AND author = ' + obj.id.toString();
                            db.sequelize.query(thisQuery, {
                                queryParams
                            }).spread(function(authorImages) {
                                var authorImageArray = new Array;
                                authorImages.forEach(function(obj) {
                                    var imgLink = { url: imgHost + obj.img_id + '.jpg', title : img_tags }
                                    authorImageArray.push(imgLink);
                                })
                            });
                            resolve(authorImageArray);
                        });
                        */
                        var authorLink = { url: 'author/' + obj.id, /*img: authorImageArray,*/ changefreq: 'weekly', priority: 0.6, lastmodrealtime: true }
                        siteMapArray.push(authorLink);
                    });
                    resolve(siteMapArray);

                    //and finally create it
                    createSiteMap(siteMapArray);
                });
            })

        });
    });
};

getPhotos();

Answer 1

好吧，让我们假设您想要这样的东西:

function getSiteMapArray() {
  // return a promise that resolves to the siteMapArray
}

第一步是在不使用 new Promise() 的情况下重写它 - 您不应该经常需要这个，因为大多数使用 Promise 的工作只是链接 .then() 调用，这更具可读性。

请注意.spread()只是一个顶部带有糖的 .then() 。该糖不是标准的 Promise 语法，而是 sequelize 建议使用的 bluebird 插件。这些对于使用具有 2 个值的数组进行解析的 Promise 是等效的:

something.then(resultArray => ...);
something.spread((resultItem1, resultItem2) => ...);

(我要使用 arrow functions ，可以吗？)

<小时/>

因此，在我们开始合并您评论中的代码之前，第一步是按照 promise 删除 new Promise():

function getSiteMapArray() {
  var authorMapArray = new Array();
  return db.sequelize
    .query(authorQuery, {
      replacements: queryParams
    })
    .spread(authorSitemap => {
      authorSitemap.forEach(function(obj) {
        var authorLink = {
          url: "author/" + obj.id,
          /*img: authorImageArray,*/
          changefreq: "weekly",
          priority: 0.6,
          lastmodrealtime: true
        };
        siteMapArray.push(authorLink);
      });
      return siteMapArray;
    });
}

足够简单吗？

• 我们使用 .query() 来获得结果 promise ，
• 然后我们使用 .then() 或 .spread() 传递处理结果的回调，
• spread() 返回一个新的 Promise，当我们完成所有操作后，该 Promise 就会解析，而这个 Promise 是 getSiteMapArray() 的结果。它将使用返回 siteMapArray 中的值进行解析。

我们可以使用 map() 进一步简化一步，而不是使用 forEach ，当您想要转换数组中的每个元素时，推荐使用 forEach:

function getSiteMapArray() {
  return db.sequelize
    .query(authorQuery, {
      replacements: queryParams
    })
    .spread(authorSitemap => {
      return authorSitemap.map(obj => ({
        url: "author/" + obj.id,
        /*img: authorImageArray,*/
        changefreq: "weekly",
        priority: 0.6,
        lastmodrealtime: true
      }));
    });
}

<小时/>

这就是简单的部分，现在我们如何在这里合并authorImage 查询？

让我先提取一个助手:

function getSiteMapArray() {
  return db.sequelize
    .query(authorQuery, {
      replacements: queryParams
    })
    .spread(authorSitemap => {
      return authorSitemap.map(getAuthorDescription);
    });
}

function getAuthorDescription(obj) {
  return {
    url: "author/" + obj.id,
    /*img: authorImageArray,*/
    changefreq: "weekly",
    priority: 0.6,
    lastmodrealtime: true
  };
}

现在 getAuthorDescription 是同步的，但我们希望它自己执行查询，所以让我们将其重写为异步，以便它也返回一个 promise !

function getAuthorDescription(obj) {
  var thisQuery = photoQuery + " AND author = " + obj.id.toString();
  return db.sequelize
    .query(thisQuery, {
      queryParams
    })
    .spread(function(authorImages) {
      var authorImageArray = new Array();
      authorImages.forEach(function(obj) {
        var imgLink = { url: imgHost + obj.img_id + ".jpg", title: img_tags };
        authorImageArray.push(imgLink);
      });
      return {
        url: "author/" + obj.id,
        img: authorImageArray,
        changefreq: "weekly",
        priority: 0.6,
        lastmodrealtime: true
      };
    });
}

另一个使用 .map() 的好例子，但我会把这个留给你。

回到原来的代码:

function getSiteMapArray() {
  return db.sequelize
    .query(authorQuery, {
      replacements: queryParams
    })
    .spread(authorSitemap => {
      return authorSitemap.map(getAuthorDescription); // !!!
    });
}

哇，现在我们遇到了麻烦 - getAuthorDescription 返回一个 Promise，因此我们使用 Promise 列表而不是值列表来解析 getSiteMapArray!

我们需要一种方法来等待从 getAuthorDescription 返回的每个 Promise 完成，并获取所有这些 Promise 的收集结果的数组。这种方式叫做Promise.all :

所以代码变成:

function getSiteMapArray() {
  return db.sequelize
    .query(authorQuery, {
      replacements: queryParams
    })
    .spread(authorSitemap => {
      return Promise.all(authorSitemap.map(getAuthorDescription));
    });
}

请告诉我这是否有帮助!