Mongo Map Snížit poprvé

Dobře, přišel jsem na něco, co si myslím můžete dělat, co chcete. Upozorňujeme, že to nemusí fungovat přesně, protože si nejsem 100% jistý vaším schématem (vzhledem k tomu, že vaše příklady ukazují refer k dispozici v typu a, ale ne b (nejsem si jistý, zda je to opomenutí nebo co vzhledem k tomu, že chcete zobrazit podle referera)... Každopádně, přišel jsem na toto:

Funkce mapy:

function() {
    var obj = {
        "types": {},
        "tags": {},
    }
    obj.types[this.type] = 1;
    if (this.tags) {
        for (var tag in this.tags) {
            obj.tags[this.tags[tag]] = 1;
        }
    }
    emit(this.refer.url, obj);
}

Funkce Snížit:

function(key, values) {
    var obj = {
        "types": {},
        "tags": {},
    }
    for (var i = 0; i < values.length; i++) {
        for (var type in values[i].types) {
            if (!type in obj.types) {
                obj.types[type] = 0;
            }
            obj.types[type] += values[i].types[type];
        }
        for (var tag in values[i].tags) {
            if (!tag in obj.tags) {
                obj.tags[tag] = 0;
            }
            obj.tags[tag] += values[i].tags[tag];
        }
    }
    return obj;
}

Takže v podstatě to funguje takto. Funkce Mapa používá klíč refer.url (co jsem uhodl na základě vašeho popisu). Takže konečný výsledek bude vypadat jako pole s _id rovná se odkaz.url (seskupuje na základě adresy URL). Poté vytvoří objekt, který má pod sebou dva objekty (typy a značky). Důvodem objektu je to, že map a redukce mohou emitovat objekt stejného formátu. Kromě toho si myslím, že by to mělo být relativně samovysvětlující (pokud nerozumíte, mohu se pokusit vysvětlit více)...

Pojďme to tedy implementovat v PHP (Za předpokladu, že $map a $reduce jsou řetězce s výše uvedeným obsaženým v nich pro stručnost):

$mapFunc = new MongoCode($map);
$reduceFunc = new MongoCode($reduce);
$query = array(
    'time' => array('$gte' => time() - (60*60*60*24*30)),
    'refer.external' => true
);
$collection = 'visits';
$command = array(
    'mapreduce' => $collection,
    'map' => $mapFunc,
    'reduce' => $reduceFunc,
    'query' => $query,
);

$statsInfo = $db->command($command);

$statsCollection = $db->selectCollection($sales['result']);

$stats = $statsCollection->find();

foreach ($stats as $stat) {
    echo $stats['_id'] .' Visited ';
    foreach ($stats['value']['types'] as $type => $times) {
        echo "Type $type $times Times, ";
    }
    foreach ($stats['value']['tags'] as $tag => $times) {
        echo "Tag $tag $times Times, ";
    }
    echo "\n";
}

Pozor, toto jsem netestoval. To je právě to, na co jsem přišel na základě mého pochopení vašeho schématu a na základě mého pochopení Mongo a jeho implementace Map-Reduce...