Первый раз Map / Уменьшить пользователя здесь и использовать MongoDB. У меня есть много данных о посещении страницы, которые я хотел бы сделать с помощью Map / Reduce. Ниже в основном то, что я хочу сделать, но как общий новичок Map / Reduce, я думаю, что это выше моих знаний!
База данных и коллекция организованы как
$mongo->dbname->visits
Образец документа:
{"url": "www.example.com", "type": "a", "refer": {"external": true, "domain": "twitter.com", "url": "http://www.twitter.com/page"}, "page": "1235", "user": "1232", "time": 1234567890}
А потом я хочу найти документы типа B с определенным тегом.
{"url": "www.example.com", "type": "b", "page": "745", "user": "1232", "time": 1234567890, "tags": {"a", "b", "c"}}
Я использую обычное PHP-расширение Mongo, если это влияет.
Хорошо, я придумал то, что, как я думаю, может делать то, что вы хотите. Обратите внимание, что это может работать некорректно, так как я не уверен на 100% вашей схемы (учитывая, что ваши примеры показывают refer
в типе a, но не b (я не уверен, что это упущение или что вы хотите взгляд от реферата) … В любом случае, вот что я придумал:
Функция отображения:
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); }
Функция уменьшения:
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; }
Так что, в основном, как это работает. Функция Map использует ключ refer.url (что я догадался на основе вашего описания). Таким образом, конечный результат будет выглядеть как массив с _id
равным refer.url (он группируется на основе url). Затем он создает объект, у которого есть два объекта (типы и теги). Причиной для объекта является то, что карта и сокращение могут излучать один и тот же объект формата. Помимо этого, я ДУМАЮ, что он должен быть относительно понятным (если вы не понимаете, я могу попытаться объяснить больше) …
Итак, давайте реализуем это в PHP (предположим, что $map
и $reduce
являются строками с указанным выше содержимым для привязки):
$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"; }
Заметьте, я не тестировал это. Это именно то, что я придумал, основываясь на моем понимании вашей схемы и моем понимании Монго и его реализации Map-Reduce …
Снижение карты уже реализовано в Mongo DB ODM:
http://www.doctrine-project.org/docs/mongodb_odm/1.0/en/reference/map-reduce.html