Mongo Aggregation

[FS1360472174]

issues

• aggregation 与mapreduce 区别

• mapreduce 需要额外的去support

[FS1360472174]

1.db.collections.aggregate( [ {$match:{}}, $group:{} ] )

先做匹配，再做聚合 mongo-aggregation-pipeline

• 为了避免聚合阶段需要扫描全表，尽量先做过滤，document过滤及document内部字段过滤 $match,$limit,$skip
• 聚合只能在单个document上
• pipeline stages ram限制为100M, 为了允许处理大的数据集，使用allowDiskUse 选项去enable 写入数据到临时files

[FS1360472174]

{ _id : "jane", joined : ISODate("2011-03-02"), likes : ["golf", "racquetball"] }

db.users.aggregate( [ { $project : { name:{$toUpper:"$_id"} , _id:0 } }, { $sort : { name : 1 } } ]

$project 可以重命名字段