MongoDB
 sql >> Baza danych >  >> NoSQL >> MongoDB

Mongo Mapa Zmniejsz pierwszy raz

Ok, wymyśliłem coś, o czym myślę może robić, co chcesz. Zauważ, że może to nie działać dokładnie, ponieważ nie jestem w 100% pewien twojego schematu (biorąc pod uwagę twoje przykłady pokazują refer dostępne w typie a, ale nie b (nie jestem pewien, czy to pominięcie, ani co, biorąc pod uwagę, że chcesz wyświetlić przez odsyłacz)... W każdym razie, oto, co wymyśliłem:

Funkcja 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);
}

Funkcja Zmniejsz:

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;
}

Więc w zasadzie, jak to działa, jest tak. Funkcja Mapa używa klucza refer.url (co domyśliłem się na podstawie twojego opisu). Tak więc wynik końcowy będzie wyglądał jak tablica z _id równy refer.url (grupuje na podstawie adresu URL). Następnie tworzy obiekt, który ma pod sobą dwa obiekty (typy i tagi). Powodem istnienia obiektu jest to, że map i Reduce mogą emitować ten sam obiekt formatu. Poza tym MYŚLĘ, że powinno to być stosunkowo oczywiste (jeśli nie rozumiesz, mogę spróbować wyjaśnić więcej)...

Więc zaimplementujmy to w PHP (Zakładając, że $map i $reduce są ciągami zawierającymi powyższe dla zwięzłości):

$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";
}

Uwaga, nie testowałem tego. Właśnie to wymyśliłem na podstawie mojego zrozumienia twojego schematu oraz mojego zrozumienia Mongo i jego implementacji Map-Reduce...



  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Mongo Podawanie błędu zduplikowanego klucza w nieunikalnych polach

  2. MongoDB $konwertuj

  3. Jak wstawić dokument MongoDB ze znacznikiem czasu z serwera bazy danych?

  4. Jak mogę dodać ciąg do każdej wartości w tablicy w Mongoose?

  5. Jak przekazać ObjectId z MongoDB w MVC.net?