javascript – 在NodeJS中处理多个,顺序,依赖的mongo查询结果的最佳方法

高水平

我是JS和Node的新手.我正在开发一个应该返回状态值的API端点.要计算状态值,我需要进行两个连续的mongo查询,其中第二组查询依赖于第一个查询.第二组查询将为我提供第一个查询中找到的每个值的状态,我将根据某些逻辑选择一个. NodeJS中最好的方法是什么？

细节

这是我第一次尝试的部分内容.

function getItemStatus(key,value,callback) {
        MongoClient.connect(mongo_url,function(err,db) {
            if (err) { return console.dir(err); }
            db.collection('status',coll) {
                if (err) { return console.dir(err); }
                coll.distinct("_id.metric",metrics) {
                    if (err) { return console.dir(err); }
                    console.log('metrics : ',metrics);
                    _.foreach(metrics,function(metric) {
                        var query = {"_id": {
                            "$gte" : {key: key,value: value,created: new Date("1800-01-01T00:00:00"),metric : metric},"$lte" : {key: key,created: new Date("2100-01-01T00:00:00"),metric : metric}}};
                        coll.find(query,{sort: {"_id.created": -1},limit: 1})

我建立连接,使用不同的查询查询一组度量值.对于每个指标,我想要询问最新状态.理想情况下,我希望拥有整套状态,以便我可以编写一个函数来获取此集合并决定返回哪个状态.我的问题是将状态传递回“链上”,以便我可以处理这组状态.

在同步的情况下,我只想写这样的东西

val metrics = getDistinctMetrics(key,value)
val statuses = metrics.map(getStatusForMetric)
val status = filterStatuses(statuses)

如何在JavaScript / NodeJS中完成此操作？

更新以突出显示第一个查询将在第二步中触发多个查询的事实,即对于第一个查询找到的每个结果一个查询.

最佳答案

据我所知,你想要以并行或瀑布模式执行查询,并对最终结果做一些逻辑.您应该查看允许并行/瀑布执行的库.像这样

瀑布：Waterfall

    async.waterfall([
    function(callback) {
        callback(null,'one','two');
    },function(arg1,arg2,callback) {
        // arg1 now equals 'one' and arg2 now equals 'two'
        callback(null,'three');
    },callback) {
        // arg1 now equals 'three'
        callback(null,'done');
    }
],function (err,result) {
    // result now equals 'done'
});

平行：Parallel

async.parallel({
    collectionOne: function (callback) {
        collectionOne.find(query,result) {
            if (err) {
                return handleError(res,err);
            }
            callback(null,result);
        })
    },collectionTwo: function (callback) {
        collectionTwo.find(query,collectionThree: function (callback) {
        collectionThree.find(query,collectionFour: function (callback) {
        collectionFour.find(query,},results) {
    return res.status(200).json(results);
});

在最后的回调中,你可以做一些逻辑或返回响应.

javascript – 在NodeJS中处理多个,顺序,依赖的mongo查询结果的最佳方法

猜你在找的JavaScript相关文章