1

誰かが次の状況の解決策を教えてくれますか?

nodeJS Express フレームワークで記述され、MongoDB コレクションを使用するロギング アプリケーションがあります。コレクションから結果を取得できましたが、結果を反復処理し、最初のクエリの参照 ID に基づいて別のコレクションをクエリし、最初の結果にさらに値を追加してから、クライアントに応答を送信したいと考えています。

今コーディングしたものを以下に貼り付けますが、うまくいきません。やり方が間違っているか、目的のロジックが正しくありません。

理論以上のものと、非同期 JS 関数の外部で結果を使用できないという事実を教えてください。

前もって感謝します！

コード：

exports.findLogs = function(req, res) {
    var params = req.body;
    var query = req.query;
    var coll = params.section;
    if (coll === undefined) {
        coll = 'traces';
    }

    db.collection(coll, function(err, collection) {
        collection.count(function(err, count) {
            var criteria = {
            'limit': limit,
                'skip': skip,
                 'sort': [[options.sortname, options.sortorder]]
             }
             collection.find({}, criteria).toArray(function(err, items) {
                 Object.keys(items).forEach(function(logIndex) {
                     var trace = items[logIndex];
                     var crit = {
                         'find': {LogId: trace.LogId},
                         'projection': {},
                         'limit': 1
                     }

                     // Get entry based on Criteria from `log` table
                     findOneBy(crit, 'log', function(err, log) {
                         if (log.length !== 1) {
                             // no reference found
                         } else {
                              // Appending here to log DOES NOT stick as expected
                             trace.ComputerName = log.ComputerName;
                             trace.ComputerIP = log.ComputerIP;
                             trace.LastSeen = log.LastSeen;
                             trace.TestVar = 'test1234';
                         }
                     });

                     // Appending here to trace works as expected
                         trace.Actions = 'MyAction';
                 });

                 results['total'] = count;
                 results['results'] = items.length;
                 results['rows'] = items;
                 res.send(results);
            });
        });
    });
}

function findOneBy(criteria, coll, callback) {
    var cFind = criteria.find;
    var cProj = criteria.projection;
    db.collection(coll, function(err, collection) {
        if (err) return callback(err);
        else return collection.find(cFind, cProj).toArray(callback);
    });
}
4

2 に答える 2

2

関数findOneByは非同期です。コードが に格納された結果の配列をループするときitems、それぞれが非同期ルックアップをトリガーしています。

ただし、これらすべてが返される前に、「res.send(results)」を介してクライアントに結果を送信しています。そのため、データが Node.JS アプリケーションに返されるのは、結果が既に送信された後です。

これを処理するにはいくつかの方法がありますが、次のようなロジックを検討することをお勧めします (データをミラーリングする DB がないため、疑似コード)。

collection.find({}, criteria).toArray(function(err, items) {
    var allLogIds = [];
    var logIdsByUse = {};
    Object.keys(items).forEach(function(logIndex) {
        // here, we'll first bit a list of all LogIds
        var trace = items[logIndex];
        allLogIds.push(trace.LogId);
        // now build a index of logId and a list of dependent objects
        logIdsByUse[trace.LogId] = [] || logIdsByUse[trace.LogId];
        logIdsByUse[trace.LogId].push(trace);
    });
    // now that the LogIds are all gathered, we'll do a search for all of them
    // at once.
    // *** You should make certain that the LogId field is indexed or this will
    // *** never perform adequately in any situation
    db.collection("log", function(err, collection) {
        if (err) { /* do something with the error, maybe 500 error */ }
        else { 
            collection.find({ LogId: { $in : allLogIds}})
                .toArray(function(err, logs) {
                    logs.forEach(function(log) {
                       // grab the LogId,
                       // get the array of traces that use the LogId
                       // from the logIdsByUse[LogId]
                       // loop through that array, and do the fix up that you
                       // want
                    });
                    // now, you may send the results                           
                    results['total'] = count;
                    results['results'] = items.length;
                    results['rows'] = items;
                    res.send(results);               
                });
    });        

});

Node.JS の非同期ライブラリの 1 つを使用することも検討できますが、必要な作業が大幅に変わることはありません。

于 2013-09-08T16:22:10.260 に答える
0 
     callMe(function(initialResults) {
             //iterate over the array or object
             //take your new results and combine them with the initial Results,
             //To be done differently depending if you have an array, object, or array of objects.
         res.send(newResults)
     }; 




     function callMe(callback) {
            //query your database and get your first results
            callback(initialResults)
     }

それは役に立ちますか？どのようなエラーや結果が得られているかを説明しない場合

于 2013-09-08T07:04:15.270 に答える