使用聚合框架计算每天的推文和转推

Question

我正在尝试使用mongo中的聚合框架计算每天转推和推文的数量，但我遇到了问题。我可以单独做到这一点，但是当我试图做到这一点只使用查询，我没有得到任何结果。

我使用的下一个聚合框架，让每一天

db.tweets.aggregate(
    [ 
    { $match: { "retweeted_status.id": {"$exists":true} }} 
    { 
     $group: 
     { 
      _id: { 
       day2: { $dayOfMonth: "$created_ts"}, 
       month2 : {$month : "$created_ts" }, 
       year2: { $year: "$created_ts" }, 
       }, 
      totalReTweetsPerDay: { $sum: 1 }, 
     } 
    }, 
     { $match: { "retweeted_status.id": {"$exists":true} }} 
    ] 
) 

锐推的数量，我用下面的代码来获得每天的鸣叫的次数

db.tweets.aggregate(
     [ 
     { 
      $group: 
      { 
       _id: { 
        day: { $dayOfMonth: "$created_ts"}, 
        month : {$month : "$created_ts" }, 
        year: { $year: "$created_ts" }, 
        }, 
       totalReTweetsPerDay: { $sum: 1 }, 


    } 
    }, 
    {$sort : { _id : -1}}, 
    {$out : "daily_tweets" } 
    ] 
) 

我想将这两项行动合为一体。我试图加入它只copyng一个里面，但它不工作。

非常感谢，

Answer 1

您可以尝试下面的聚合。唯一要注意的是包含ifNull运算符，它检查字段的存在。

db.tweets.aggregate(
    [{ 
     $group: { 
      _id: { 
       day: { 
        $dayOfMonth: "$created_ts" 
       }, 
       month: { 
        $month: "$created_ts" 
       }, 
       year: { 
        $year: "$created_ts" 
       }, 
      }, 
      totalReTweetsPerDay: { 
       $sum: { 
        $cond: [{ 
         $ifNull: ["$retweeted_status.id", false] 
        }, 1, 0] 
       } 
      }, 
      totalTweetsPerDay: { 
       $sum: 1 
      } 
     } 
    }, { 
     $sort: { 
      _id: -1 
     } 
    }, { 
     $out: "daily_tweets" 
    }] 
)