MongoDB : Aggregation mongo聚合操作详细说明

loip

This page last changed on Feb 02, 2012 by
dwight.

• Aggregation Framework
  
• Count
  
• Distinct
  
• Group
  
  
  
  • Examples
    
  • Using Group from Various Languages
    
  
  
  
• Map/Reduce
  
• See Also
  

　　Mongo includes utility functions which provide server-side count, distinct, and
group by operations.  More advanced aggregate functions can be crafted using
MapReduce.

Aggregation Framework
　　v2.2+
　　This is a new module in the v2.2 release.  You can test it via v2.1.0 in the 2.1 development (unstable) branch.
Aggregation Framework

Count
　　count() returns the number of objects in a collection or matching a query. If a document selector is provided, only the number of matching documents will be returned.
　　size() is like count() but takes into consideration any limit() or skip() specified for the query.

db.collection.count(selector);

　　For example:

print( "# of objects: " + db.mycollection.count() );
print( db.mycollection.count( {active:true} );

　　count is faster if an index exists for the condition in the selector. For example, to make the count on
active fast, invoke

db.mycollection.ensureIndex( {active:1} );
Distinct
　　The distinct command returns returns a list of distinct values for the given
key across a collection.
　　Command is of the form:

{ distinct : <collection_name>, key : <key>[, query : <query>] }
　　although many drivers have a helper function for distinct.

> db.addresses.insert({&quot;zip-code&quot;: 10010})
> db.addresses.insert({&quot;zip-code&quot;: 10010})
> db.addresses.insert({&quot;zip-code&quot;: 99701})
> // shell helper:
> db.addresses.distinct(&quot;zip-code&quot;);
[ 10010, 99701 ]
> // running as a command manually:
> db.runCommand( { distinct: 'addresses', key: 'zip-code' } )
{ &quot;values&quot; : [ 10010, 99701 ], &quot;ok&quot; : 1 }

　　distinct may also reference a nested key:

> db.comments.save({&quot;user&quot;: {&quot;points&quot;: 25}})
> db.comments.save({&quot;user&quot;: {&quot;points&quot;: 31}})
> db.comments.save({&quot;user&quot;: {&quot;points&quot;: 25}})
> db.comments.distinct(&quot;user.points&quot;);
[ 25, 31 ]

　　You can add an optional query parameter to distinct as well

> db.address.distinct( &quot;zip-code&quot; , { age : 30 } )
　　Note: the distinct command results are returned as a single BSON object.  If the results could be large (> max document size – 4/16MB ), use map/reduce instead.



Covered Index Use

Starting with 1.7.3 distinct can use an index not only to find the documents in the query, but also to return the data.

Group
　　Note: currently one must use map/reduce instead of group() in sharded MongoDB configurations.
　　group returns an array of grouped items. The command is similar to SQL's group by. The SQL statement

select a,b,sum(c) csum from coll where active=1 group by a,b

　　corresponds to the following in MongoDB:

db.coll.group(
{key: { a:true, b:true },
cond: { active:1 },
reduce: function(obj,prev) { prev.csum &#43;= obj.c; },
initial: { csum: 0 }
});

　　Note: the result is returned as a single BSON object and for this reason must be fairly small – less than 10,000 keys, else you will get an exception. For larger grouping operations without limits, please use
map/reduce .
　　group takes a single object parameter containing the following fields:

• key: Fields to group by.
  
• reduce: The reduce function aggregates (reduces) the objects iterated. Typical operations of a reduce function include summing and counting.
  reduce takes two arguments: the current document being iterated over and the aggregation counter object. In the example above, these arguments are named
  obj and prev.
  
• initial: initial value of the aggregation counter object.
  
• keyf: An optional function returning a &quot;key object&quot; to be used as the grouping key. Use this instead of
  key to specify a key that is not a single/multiple existing fields. Could be used to group by day of the week, for example. Set in lieu of
  key.
  
• cond: An optional condition that must be true for a row to be considered. This is essentially a
  find() query expression object. If null, the reduce function will run against all rows in the collection.
  
• finalize: An optional function to be run on each item in the result set just before the item is returned. Can either modify the item (e.g., add an average field given a count and a total) or return a replacement object (returning a new
  object with just _id and average fields). See jstests/group3.js for examples.
  

　　To order the grouped data, simply sort it client-side upon return. The following example is an implementation of
count() using group().

function gcount(collection, condition) {
var res =
db[collection].group(
{ key: {},
initial: {count: 0},
reduce: function(obj,prev){ prev.count&#43;&#43;;},
cond: condition } );
// group() returns an array of grouped items.  here, there will be a single
  // item, as key is {}.
  return res[0] ? res[0].count : 0;
}

Examples
　　The examples assume data like this:

{ domain: &quot;www.mongodb.org&quot;
, invoked_at: {d:&quot;2009-11-03&quot;, t:&quot;17:14:05&quot;}
, response_time: 0.05
, http_action: &quot;GET /display/DOCS/Aggregation&quot;
}

　　Show me stats for each http_action in November 2009:

db.test.group(
{ cond: {&quot;invoked_at.d&quot;: {$gte: &quot;2009-11&quot;, $lt: &quot;2009-12&quot;}}
, key: {http_action: true}
, initial: {count: 0, total_time:0}
, reduce: function(doc, out){ out.count&#43;&#43;; out.total_time&#43;=doc.response_time }
, finalize: function(out){ out.avg_time = out.total_time / out.count }
} );
[
{
&quot;http_action&quot; : &quot;GET /display/DOCS/Aggregation&quot;,
&quot;count&quot; : 1,
&quot;total_time&quot; : 0.05,
&quot;avg_time&quot; : 0.05
}
]

　　Show me stats for each domain for each day in November 2009:

db.test.group(
{ cond: {&quot;invoked_at.d&quot;: {$gte: &quot;2009-11&quot;, $lt: &quot;2009-12&quot;}}
, key: {domain: true, invoked_at.d: true}
, initial: {count: 0, total_time:0}
, reduce: function(doc, out){ out.count&#43;&#43;; out.total_time&#43;=doc.response_time }
, finalize: function(out){ out.avg_time = out.total_time / out.count }
} );
[
{
&quot;http_action&quot; : &quot;GET /display/DOCS/Aggregation&quot;,
&quot;count&quot; : 1,
&quot;total_time&quot; : 0.05,
&quot;avg_time&quot; : 0.05
}
]

Using Group from Various Languages
　　Some language drivers provide a group helper function.  For those that don't, one can manually issue the db command for group.  Here's an example using the Mongo shell syntax:

> db.foo.find()
{&quot;_id&quot; :  ObjectId( &quot;4a92af2db3d09cb83d985f6f&quot;)  , &quot;x&quot; : 1}
{&quot;_id&quot; :  ObjectId( &quot;4a92af2fb3d09cb83d985f70&quot;)  , &quot;x&quot; : 3}
{&quot;_id&quot; :  ObjectId( &quot;4a92afdab3d09cb83d985f71&quot;)  , &quot;x&quot; : 3}
> db.$cmd.findOne({group : {
... ns : &quot;foo&quot;,
... cond : {},
... key : {x : 1},
... initial : {count : 0},
... $reduce : function(obj,prev){prev.count&#43;&#43;;}}})
{&quot;retval&quot; : [{&quot;x&quot; : 1 , &quot;count&quot; : 1},{&quot;x&quot; : 3 , &quot;count&quot; : 2}] , &quot;count&quot; : 3 , &quot;keys&quot; : 2 , &quot;ok&quot; : 1}

　　If you use the database command with keyf (instead of key) it must be prefixed with a $. For example:

db.$cmd.findOne({group : {
... ns : &quot;foo&quot;,
... $keyf : function(doc) { return {&quot;x&quot; : doc.x}; },
... initial : {count : 0},
... $reduce : function(obj,prev) { prev.count&#43;&#43;; }}})

Map/Reduce
　　MongoDB provides a
MapReduce facility for more advanced aggregation needs. CouchDB users: please note that basic queries in MongoDB do not use map/reduce.

See Also

• jstests/eval2.js for an example of group() usage
  
• Advanced Queries
  

　　site:
http://api.mongodb.org/wiki/current/Aggregation.html#Aggregation-Group