承诺的mongo：无法完成承诺

Question

这是我正在处理的一段代码：它将 reddit 帖子保存到 mongoDB 集合中。

我正在使用promised-mongo 库

问题是当for循环完成并且所有数据都保存到数据库时，程序没有退出，它继续执行什么都不做，尽管done()在每个promise-mongo承诺链的末尾被调用。

    for (var i = 0; i< posts.length; i++) { 
        posts[i].done = false;
        DB.posts.findOne({
            "id" : posts[i].id // it's 'id', not mongo's '_id'
        })
        .then(function(i) {
            return function(doc){
                if(doc) {
                    console.log('skipping')
                } else {
                    DB.posts.insert(posts[i]).then(function() {
                        console.log(arguments);
                        nSaved++;
                    });
                }
            }
        }(i))
        .catch(function(){
            console.log(arguments)
        })
        .done();
    }

我做错了什么？

Answer 1

这里有几个问题：

• 您在 for 循环中创建了多个 Promise，但没有跟踪它们
• 你有一个 DB.posts.insert 来创建一个承诺，但你没有在等待它

以相反的顺序解决它们：

如果您不返回由DB.posts.insert 创建的承诺，则在完成之前将无法等待。您需要退货：

return function(doc){
    if(doc) {
        console.log('skipping')
    } else {
        // here
        return DB.posts.insert(posts[i]).then(function() {
            console.log(arguments);
            nSaved++;
        });
    }
}

您还需要跟踪您正在创建的所有承诺，以便您知道它们何时完成。一个简单的方法是使用.map() 将它们映射到一组promise，然后使用Promise.all() 等待它们。

假设posts是一个数组：

function ensurePost(post) {
    post.done = false;

    return DB.posts.findOne({
        "id" : post.id // it's 'id', not mongo's '_id'
    })
    .then(function(doc){
        if(doc) {
            console.log('skipping ' + post.id)
        } else {
            return DB.posts.insert(post).then(function() {
                console.log(arguments);
                nSaved++;
            });
        }
    })
    .catch(function(error){
        console.error('Error inserting', post.id, error);
    });
}

Promise.all(posts.map(ensurePost))
.done(function () {
    // all done. close the connection
});

这也消除了您在那里遇到的不愉快的 IIFE 的需要。