我将推文保存到MongoDB:
twit.stream('statuses/filter', {'track': ['animal']}, function(stream) {
stream.on('data', function(data) {
console.log(util.inspect(data));
data.created_at = new Date(data.created_at);
collectionAnimal.insert(data, function(err, docs) {});
});
});
没问题。
MongoDB中的推文时间格式为:2014-04-25 11:45:14 GMT(列名为created_at) 现在我需要按小时对列created_at进行分组。 我想要以下结果:
小时 | 每小时推文数量
1 | 28
2 | 26
3 | 32
4 | 42
5 | 36
...
我的尝试失败了:
$keys = array('created_at' => true);
$initial = array('count' => 0);
$reduce = "function(doc, prev) { prev.count += 1 }";
$tweetsGroup = $this->collectionAnimal->group( $keys, $initial, $reduce );
但我不能按小时分组。
该怎么做?