Блог

Главная - Вопросы по программированию - асинхронный запрос nodejs и обработка результатов

асинхронный запрос nodejs и обработка результатов

#asynchronous #mongodb #node.js

#асинхронный #mongodb #node.js

Вопрос:

У меня есть массив объектов, взятых из mongodb. Каждый элемент в массиве представляет собой сообщение с идентификатором пользователя author. Теперь я хочу найти информацию о пользователе, связанную с идентификатором пользователя.

Поскольку узел использует асинхронные методы для поиска данных из базы данных, цикл forEach завершается до завершения обратных вызовов.

 docs.forEach(function(doc, index){
        //get the user for this doc
        User.find({_id: mongo.BSONPure.ObjectID(doc.user_id)}, {name: 1, username: 1, email: 1}).skip(0).limit(1).toArray(function(err, user){
            user = user[0]
            if(err) {
                throw new Error(err)
            } else {
                docs[index].user = user
                if(doc.for_id) {
                    User.find({_id: mongo.BSONPure.ObjectID(doc.for_id)}, {name: 1, username: 1, email: 1}).skip(0).limit(1).toArray(function(err, for_user){
                        for_user = for_user[0]
                        if(err) {
                            throw new Error(err)
                        } else {
                            docs[index].for_user = for_user
                        }
                    })
                }
            }
        })
    })

Итак, в конце этого цикла, если я отправлю cb (docs), у документов не будет атрибута user и for_user. Как мне преодолеть это?

Комментарии:

1. Функция обратного вызова forEach принимает только один параметр, который является указателем на текущий документ > mongodb.org/display/DOCS/Queries and Cursors . В вашем примере индекс не должен быть определен

2. пожалуйста, перефразируйте заголовок вашего вопроса, потому что он не является описательным

Ответ №1:

Используйте шаг для node.js . Он будет запускать ваши функции в последовательном порядке

 var Step = require('step');

Step(  docs.forEach(...), function() { cb(docs); } );

Или, если вы знаете общее количество записей, вы можете вызвать обратный вызов, когда закончите обработку последней. Что-то вроде этого

 var count = docs.count(); // or something
var processed = 0;
docs.forEach(... if (  processed == count) cb(docs); );