MongoDB Mapreduce: requête/restriction/filtre sur le résultat de mapreduce?

Question

En interrogeant une base de données mongoDB avec map_reduce, j'ai besoin de limiter les résultats réels. J'espérais utiliser l'option query mais cela ne limite que les données de la partie map. Je dois limiter la sortie.

Mes données se présente comme suit (de gauche d'autres attributs out):

obj1: { name: "obj1", version: 1, someAttr = "a" }, 
obj1a: { name: "obj1", version: 2, someAttr= "b"}, 

obj2: { name: "obj2", version: 1 }, 
obj2a: { name: "obj2", version: 2} ... 

J'ai des objets qui partagent la même name par version (qui est incrémenté par mise à jour).

Je dois obtenir la nouvelle version de chaque objet, et j'ai carte écrite/réduire les fonctions (il est fait en mongomapper):

MAP:

function() { 
    emit(this.name, this); 
} 

REDUCE:

function(key, values) { 
    var res = values[0]; 
    for(var i=1; i<values.length; i++) 
    { 
    if(values[i].version >res.version) 
    { 
     res = values[i]; 
    } 
    } 
    return res; 
} 

De temps en temps Je dois limiter les résultats et je justifie l'option query pour cela. Cela fonctionne bien, sauf dans un cas d'utilisation:

J'ai besoin de la dernière version de obj1 qui a également someAttr mis à "a".

Alors que j'ai essayé en query est:

name: "obj1", someAttr: "a" 

Le résultat attendu est un résultat vide parce que la dernière version n'a pas someAttr ensemble à "a". Ce que je suis est obj1 avec la version 1 ...

Comment puis-je limiter la sortie uniquement les objets avec someAttr ensemble à "a"?

Answer 1

Vous pouvez ajouter à votre réduire la fonction

function(key, values) { 
    var res = values[0]; 
    for(var i=1; i<values.length; i++) 
    { 
    if(values[i].version >res.version) 
    { 
     res = values[i]; 
    } 
    } 
    if ('someAttr' in res && res.someAttr == "a") 
    return res; 
} 

Ou si vous voulez vérifier la dernière version entre seulement ceux qui ont someAttr réglé sur « a » que vous pouvez faire

function(key, values) { 
    var res = {version : 0} 
    for(var i=0; i<values.length; i++) 
    { 
    if('someAttr' in res && res.someAttr == "a" && values[i].version >res.version) 
    { 
     res = values[i]; 
    } 
    } 
    return res; 
}