在 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 语法，而是bluebird 推荐使用的bluebird 的插件。这些等价于使用具有 2 个值的数组解析的承诺：

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

（我要使用arrow functions，可以吗？）

---

所以第一步是按照承诺删除new Promise()，然后我们开始合并您的 cmets 中的代码：

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() 来获得结果承诺，
• 然后我们使用.then() 或.spread() 传递处理结果的回调，
• spread() 返回一个新的 Promise，当我们完成所有事情时它会解析，这个 Promise 是 getSiteMapArray() 的结果。它将使用来自 return siteMapArray 的值解决。

我们可以使用map() 而不是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 是同步的，但我们希望它自己进行查询，所以让我们将其重写为异步，以便它也返回一个承诺！

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 返回一个承诺，所以我们用承诺列表而不是值列表来解析 getSiteMapArray！

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

所以代码变成了：

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

如果这有帮助，请告诉我！

Answer 2

您的实施中有几个问题。我建议不要将[].foreach 用于儿童承诺。为子承诺创建单独的方法，并使用 promise.all 为每个 authorSitemap 调用它。

以下是带有更新的示例实现。

return new Promise(function(resolve, reject) {
            var authorMapArray = new Array
            db.sequelize.query(authorQuery, {
                replacements: queryParams
            }).spread(function(authorSitemap) {

                return Promise.all(authorSitemap.map(GetAuthor))
                .then(function(authorImageArray){
                    var authorLink = { url: 'author/' + obj.id, img: authorImageArray, changefreq: 'weekly', priority: 0.6, lastmodrealtime: true }
                    siteMapArray.push(authorLink);
                    createSiteMap(siteMapArray);
                    resolve(siteMapArray);
                })
                .catch(function(error){
                    reject(error);
                })
            });
        })

function GetAuthor(obj) {
    return new Promise(function(reject,resolve){
        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);
                        });
    })
}