0

我有一个收藏

{ "_id" : 1325376000, "value" : 13393}
{ "_id" : 1325462400, "value" : 13393}

ObjectIds 是 Unix 时间戳,并且手动存储为 Number。(在插入时)。

现在我正在寻找一个解决方案,我可以使用聚合框架计算每个月的值总和。

4

1 回答 1

2

您可以通过以下方式以编程方式生成聚合管道:

numberOfMonths=24;   /* number of months you want to go back from today's */
now=new Date();
year=now.getFullYear();
mo=now.getMonth();
months=[];
for (i=0;i<numberOfMonths;i++) {
      m1=mo-i+1; m2=m1-1;
      d = new Date(year,m1,1); 
      d2=new Date(year,m2,1);
      from= d2.getTime()/1000; 
      to= d.getTime()/1000;
      dt={from:from, to:to, month:d2};  months.push(dt); 
}
prev="$nothing";
cond={};
months.forEach(function(m) { 
      cond={$cond: [{$and :[ {$gte:["$_id",m.from]}, {$lt:["$_id",m.to]}  ]}, m.month, prev]}; 
      prev=cond; 
} );

/* now you can use "cond" variable in your pipeline to generate month */
db.collection.aggregate( { $project: { month: cond , value:1 } }, 
                         { $group: {_id:"$month", sum:{$sum:"$value"} } }
)
于 2013-06-25T19:24:33.297 回答