php - MongoMapReduceの初回

Question

ここで初めてユーザーをMap/Reduceし、MongoDBを使用します。Map/Reduceを使用して理解したいページ訪問データがたくさんあります。以下は基本的に私がやりたいことですが、完全な初心者としてMap / Reduceを使用することで、これは私の知識を超えていると思います。

過去30日間に訪問したすべてのページを確認します。ここで、external=trueです。
次に、各ページについて、すべての訪問を検索します
すべての訪問を紹介場所ごとにグループ化します
紹介場所ごとに、特定の「タイプ」と「タグ」に特定の単語が含まれるページにアクセスした回数を計算します。

データベースとコレクションは次のように編成されています

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

影響がある場合は、通常のMongoPHP拡張機能を使用しています。

score 16 · Accepted Answer

わかりました、私はあなたが望むことをするかもしれないと思う何かを思いつきました. 私はあなたのスキーマを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 のキーを使用します (あなたの説明に基づいて私が推測したもの)。したがって、最終結果は、_idrefer.url に等しい配列のようになります (URL に基づいてグループ化されます)。次に、その下に 2 つのオブジェクト (型とタグ) を持つオブジェクトを作成します。オブジェクトの理由は、map と reduce が同じ形式のオブジェクトを発行できるようにするためです。それ以外は、比較的自明であるべきだと思います（理解できない場合は、もっと説明しようとします）...

それでは、これを 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";
}

注、私はこれをテストしていません。これは、あなたのスキーマの理解と、Mongo とその Map-Reduce 実装の理解に基づいて思いついたものです...

score 0 · Accepted Answer

Map reduce は Mongo DB ODM で既に実装されています。

http://www.doctrine-project.org/docs/mongodb_odm/1.0/en/reference/map-reduce.html

php - MongoMapReduceの初回

2 に答える 2

Related

Reference