微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

php – Mongo Map首先减少

首先Map /减少用户在这里,并使用MongoDB.我有很多页面访问数据,我想通过使用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","time": 1234567890,"tags": {"a","b","c"}}

我正在使用正常的Mongo PHP扩展,如果有影响.

好的,我想出了我认为可以做你想要的东西.注意,这可能无法正常工作,因为我不是100%确定您的模式(考虑到您的示例显示参考可用类型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": {},}
    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进行分组).然后,它创建一个对象,其下有两个对象(类型和标签).对象的原因是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实现的理解…

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


统一支付是JSAPI/NATIVE/APP各种支付场景下生成支付订单,返回预支付订单号的接口,目前微信支付所有场景均使用这一接口。下面介绍的是其中NATIVE的支付实现流程与PC端实现扫码支付流程
统一支付是JSAPI/NATIVE/APP各种支付场景下生成支付订单,返回预支付订单号的接口,目前微信支付所有场景均使用这一接口。下面介绍的是其中APP的支付的配置与实现流程
前言 之前做了微信登录,所以总结一下微信授权登录并获取用户信息这个功能的开发流程。 配置 1.首先得在微信公众平台申请一下微信小程序账号并获取到小程序的AppID和AppSecret https://mp.weixin.qq.com/cgi-bin/loginpage?url=%2Fwxamp%2F
FastAdmin是我第一个接触的后台管理系统框架。FastAdmin是一款开源且免费商用的后台开发框架,它基于ThinkPHP和Bootstrap两大主流技术构建的极速后台开发框架,它有着非常完善且强大的功能和便捷的开发体验,使我逐渐喜欢上了它。
之前公司需要一个内部的通讯软件,就叫我做一个。通讯软件嘛,就离不开通讯了,然后我就想到了长连接。这里本人用的是GatewayWorker框架。
统一支付是JSAPI/NATIVE/APP各种支付场景下生成支付订单,返回预支付订单号的接口,目前微信支付所有场景均使用这一接口。下面介绍的是其中JSAPI的支付实现流程
服务器优化必备:深入了解PHP8底层开发原理
Golang的网络编程:如何快速构建高性能的网络应用?
Golang和其他编程语言的对比:为什么它的开发效率更高?
PHP8底层开发原理揭秘:如何利用新特性创建出色的Web应用