我对 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();
最佳答案
好吧，让我们假设您想要这样的东西:
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));
});
}
请告诉我这是否有帮助!
关于javascript - 将 Promise 嵌入 Promise 中，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/49691747/