Come posso selezionare un numero di record per un campo specifico utilizzando mongodb?

Non puoi ancora farlo usando il framework di aggregazione:puoi ottenere il valore $max o la data massima per ogni gruppo ma il framework di aggregazione non ha ancora un modo per accumulare i primi N più non c'è modo di inserire l'intero documento nel set di risultati (solo singoli campi).

Quindi devi ricorrere a MapReduce. Ecco qualcosa che funzionerebbe, ma sono sicuro che ci sono molte varianti (tutte richiedono in qualche modo l'ordinamento di una matrice di oggetti in base a un attributo specifico, ho preso in prestito la mia soluzione da uno dei le risposte a questa domanda .

Funzione Mappa:restituisce il nome del gruppo come chiave e l'intero resto del documento come valore, ma lo restituisce come un documento contenente un array perché cercheremo di accumulare un array di risultati per gruppo:

map = function () { 
    emit(this.name, {a:[this]}); 
}

La funzione reduce accumulerà tutti i documenti appartenenti allo stesso gruppo in un array (tramite concat). Nota che se ottimizzi reduce per mantenere solo i primi cinque elementi dell'array controllando la data, non avrai bisogno della funzione finalize e utilizzerai meno memoria durante l'esecuzione di mapreduce (sarà anche più veloce).

reduce = function (key, values) {
    result={a:[]};
    values.forEach( function(v) {
        result.a = v.a.concat(result.a);
    } );
    return result;
}

Dal momento che sto mantenendo tutti i valori per ogni chiave, ho bisogno di una funzione di finalizzazione per estrarre solo gli ultimi cinque elementi per chiave.

final = function (key, value) {
      Array.prototype.sortByProp = function(p){
       return this.sort(function(a,b){
       return (a[p] < b[p]) ? 1 : (a[p] > b[p]) ? -1 : 0;
      });
    }

    value.a.sortByProp('date');
    return value.a.slice(0,5);
}

Usando un documento modello simile a quello che hai fornito, lo esegui chiamando il comando mapReduce:

> db.top5.mapReduce(map, reduce, {finalize:final, out:{inline:1}})
{
    "results" : [
        {
            "_id" : "group1",
            "value" : [
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfe13"),
                    "name" : "group1",
                    "date" : ISODate("2013-04-17T20:07:59.498Z"),
                    "contents" : 0.23778377776034176
                },
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfe0e"),
                    "name" : "group1",
                    "date" : ISODate("2013-04-17T20:07:59.467Z"),
                    "contents" : 0.4434165076818317
                },
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfe09"),
                    "name" : "group1",
                    "date" : ISODate("2013-04-17T20:07:59.436Z"),
                    "contents" : 0.5935856597498059
                },
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfe04"),
                    "name" : "group1",
                    "date" : ISODate("2013-04-17T20:07:59.405Z"),
                    "contents" : 0.3912118375301361
                },
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfdff"),
                    "name" : "group1",
                    "date" : ISODate("2013-04-17T20:07:59.372Z"),
                    "contents" : 0.221651989268139
                }
            ]
        },
        {
            "_id" : "group2",
            "value" : [
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfe14"),
                    "name" : "group2",
                    "date" : ISODate("2013-04-17T20:07:59.504Z"),
                    "contents" : 0.019611883210018277
                },
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfe0f"),
                    "name" : "group2",
                    "date" : ISODate("2013-04-17T20:07:59.473Z"),
                    "contents" : 0.5670706110540777
                },
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfe0a"),
                    "name" : "group2",
                    "date" : ISODate("2013-04-17T20:07:59.442Z"),
                    "contents" : 0.893193120136857
                },
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfe05"),
                    "name" : "group2",
                    "date" : ISODate("2013-04-17T20:07:59.411Z"),
                    "contents" : 0.9496864483226091
                },
                {
                    "_id" : ObjectId("516f011fbfd3e39f184cfe00"),
                    "name" : "group2",
                    "date" : ISODate("2013-04-17T20:07:59.378Z"),
                    "contents" : 0.013748752186074853
                }
            ]
        },
        {
            "_id" : "group3",
                        ...
                }
            ]
        }
    ],
    "timeMillis" : 15,
    "counts" : {
        "input" : 80,
        "emit" : 80,
        "reduce" : 5,
        "output" : 5
    },
    "ok" : 1,
}

Ogni risultato ha _id come nome del gruppo e valori come matrice dei cinque documenti più recenti della raccolta per quel nome di gruppo.