MongoDB的聚合 - 总和，其中

类似下面一个大的数据集我想运行在MongoDB中的聚集这将是该SQL相当于：

SELECT SUM(cores) from machines 
WHERE idc='AMS' AND cluster='1' AND type='Physical';

我该如何去关于在MongoDB中进行此操作？

[ 
    { 
     "_id" : "55d5dc40281077b6d8af1bfa", 
     "hostname" : "x", 
     "domain" : "domain", 
     "description" : "VMWare ESXi 5", 
     "cluster" : "1", 
     "type" : "Physical", 
     "os" : "EXSi", 
     "idc" : "AMS", 
     "environment" : "DR", 
     "deviceclass" : "host", 
     "cores" : "64", 
     "memory" : "256", 
     "mounts" : [ ], 
     "roles" : [ 
       "ESX-HOST" 
     ], 
     "ipset" : { 
       "backnet" : "1" 
     }, 
     "frontnet" : [ ], 
     "created" : "2015-09-08T07:35:03.343Z" 
    }, 
    { 
     "_id" : "55d5dc40281077b6d8af1bfb", 
     "hostname" : "x", 
     "domain" : "domain", 
     "description" : "VMWare ESXi 5", 
     "cluster" : "1", 
     "type" : "Physical", 
     "os" : "EXSi", 
     "idc" : "AMS", 
     "environment" : "DR", 
     "deviceclass" : "host", 
     "cores" : "64", 
     "memory" : "256", 
     "mounts" : [ ], 
     "roles" : [ 
       "ESX-HOST" 
     ], 
     "ipset" : { 
       "backnet" : "1" 
     }, 
     "frontnet" : [ ], 
     "created" : "2015-09-08T07:35:03.346Z" 
    } 
]

来源

2015-09-08 Corbin

有手册中的网页的所有作为示例的通用操作：[SQL到聚合映射图]（http://docs.mongodb.org/v3 0.0 /参考/ SQL-聚集比较/）。我建议你阅读它 –

你真的不需要为此聚合。我认为使用想要的是['.count']（http://docs.mongodb.org/manual/reference/method/db.collection.count/），因为它（SUM）（_id）在这里没有意义。 – styvane

对不起 - 错字 - 现在它应该更有意义 – Corbin

首先您需要更新您的文档，因为cores值是字符串而不是数字。为此，我们使用"Bulk"操作。

var bulk = db.machines.initializeOrderedBulkOp(), 
    count = 0; 
db.machines.find({ "cores": { "$type": 2 }}).forEach(function(doc){ 
    var cores = parseInt(doc.cores); 
    bulk.find({ "_id": doc._id }).update({  
     "$set": { "cores": cores } }) 
     count++; 
     if (count % 200 == 0){ 
      // execute per 200 operations and re-init 
      bulk.execute();  
      bulk = db.machines.initializeOrderedBulkOp(); 
     } 
    }) 

// clean up queues 
if (count % 200 != 0) 
    bulk.execute();

然后，使用聚合框架，然后我们可以得到cores总和。首先，我们需要使用$match运算符和$group阶段过滤我们的文档，我们使用$sum运算符获得cores值的总和。

db.machines.aggregate([ 
    { "$match": { "idc": "AMS", "cluster": "1", "type": "Physical" }}, 
    { "$group": { "_id": null, "sum_cores": { "$sum": "$cores" }}} 
])

它返回：

{ "_id" : null, "sum_cores" : 128 }

来源

2015-09-08 08:39:45 styvane

虽然我没有执行它来测试它检查：

db.<collection>.aggregation([ 
{$match: { 
     idc: 'AMS', 
     cluster: 1, 
     type:'Physical' 
    } 
}, 
{$group: { 
      _id: null, 
      sum: {$sum: "$_id"} 
    } 
}, 
{$project: { 
     _id:0, 
     sum:1 
    } 
}

]）

来源

2015-09-08 08:00:05

我认为使用聚合框架是不可能的，因为'cores'保存为string，目前mongo不允许在$project流水线阶段作为数字投射字符串。使用简单的JavaScript 相同的结果：

var tmp = db.cores.find({idc: 'AMS', cluster: '1', type: 'Physical'}, {_id: 0, cores: 1}) 
var totalCores = 0; 
tmp.forEach(function(doc) { 
    totalCores += parseInt(doc.cores); 
}) 

print(totalCores)

，如果我理解正确的问题。

来源

2015-09-08 08:39:37 SzymonK

MongoDB的聚合 - 总和，其中

回答

相关问题