mongodb mapreduce - ein Array oder ein Objekt im Reduce erstellen?

Question

ursprüngliche Sammlung:

{ 
"_id" : ObjectId('xxxxxxxxxxxxxxxx'), 
    "userId" : ObjectId('yyyyyyyyyyyyyyyy'), 
    "urlId" : ObjectId('zzzzzzzzzzzzzzzzzz') 
}, 
{ 
    "_id" : ObjectId('uuuuuuuuuuuuuuuuuu'), 
    "userId" : ObjectId('aaaaaaaaaaaaaaaa'), 
    "urlId" : ObjectId('zzzzzzzzzzzzzzzzzz') 
} 

emittieren:

emit(this.urlId, {userId: this.userId, visitCount: this.visitCount}); 

reduzieren:

function(key, values) { 
    var visitCount = 0; 
    var userVC = new Array(); 
    values.forEach(function(doc) { 


NOT SURE WHAT TO PUT HERE TO ACHIEVE DESIRED OUTPUT COLLECTION 


    }); 
    return {urlId: key, userVC: userVC}; 
}; 

MR Ausgang Sammlung gewünscht:

{ 
    "_id" : ObjectId('zzzzzzzzzzzzzzzzzzzz'), 
    "value" : { 
     "urlId" : ObjectId('zzzzzzzzzzzzzzzzzzzz'), 
     "userVC" : { 
       ObjectId('yyyyyyyyyyyyyyyy') : <total visit count for this userId on this urlId>, 
       ObjectId('aaaaaaaaaaaaaaaa') : <total visit count for this userId on this urlId> 
     } 
} 

Answer 1

Sie wollen t o wissen, wie oft jeder Benutzer jede einzelne URL auf Ihrer Website besucht hat? Ich denke, du wirst das anders lösen wollen.

Emit eine Anzahl von URL/user Besuche:

emit({ urlId: this.urlId, userId: this.userId }, { count: 1 }); 

Zähle sie die mit reduzieren:

r = function(key , values){ 
    var total = 0; 
    for (var i=0; i<values.length; i++) 
     total += values[i].count; 
    return { count : total }; 
}; 

Dann, wenn Sie wirklich, wirklich die gewünschte Ausgabe, die Sie angegeben wollten, könnten Sie das tun in ein Abschlussschritt. Aber ich denke, dass es für N Benutzer nicht gut skaliert.

Hier ist ein Link, der nicht genau Ihr erklärtes Ziel nicht erfüllt, aber ich fand, sehr nützlich, wenn man versucht zu verstehen, wie diese mongodb mapreduce Funktionen arbeiten:

http://cookbook.mongodb.org/patterns/unique_items_map_reduce/

Answer 2

Für jemand anderes dieses Problem zu lösen versuchen, in der Funktion reduzieren:

function reduce(key, values) { 
    const result = { 
    list: [], 
    ... 
    }; 

    // keep track of reduced records to avoid duplicate list entries 
    const processed = { 
    list: [], 
    ... 
    }; 

    values.forEach((value, index) => { 
    if (value.listItem && value.listItem.length > 0) { 

     // our value is an array as MongoDB needs to be strongly typed (same as reduced type) 
     if (processed.list.indexOf(value.listItem[0].key) === -1) { 
     result.list = result.list.concat(value.listItem); 
     } 

    } 
    ... 
    }); 

    return result; 
} 

die verringern Funktion im Zusammenhang mit MongoDB läuft, so dass Sie sich bewusst sein müssen, was in der Funktion geht, die unterstützt wird.