精品久久久久久无码专区不卡,精品久久久久久成人AV,99久久人妻无码精品系列

MongoDb 用 mapreduce 統(tǒng)計(jì)留存率

MongoDb 用 mapreduce 統(tǒng)計(jì)留存率

(金慶的專欄)

留存的定義采用的是
新增賬號(hào)第X日：某日新增的賬號(hào)中，在新增日后第X日有登錄行為記為留存

輸出如下：（類同友盟的留存率顯示）
留存用戶
注冊(cè)時(shí)間    新增用戶留存率
                      1天后   2天后   3天后   4天后   5天后 6天后 7天后 14天后 30天后
2015-09-17 2300      20.7 % 15.6 % 13 %    11.3 % 9.9 %
2015-09-18 2694      21.8 % 14.8 % 11.5 % 10.5 %
2015-09-19 3325      19 %    11.4 % 10.3 %
2015-09-20 3093      16.2 % 11.9 %
2015-09-21 2303      20.5 %

服務(wù)器記錄新建帳號(hào)到 retention.register 集合，
每日記錄帳號(hào)登錄到 retention.login 集合，
每日運(yùn)行統(tǒng)計(jì)腳本，統(tǒng)計(jì)前一天的留存率。

以下為 mongoDB 留存率相關(guān)的集合,
除了 retention.register 和 retention.login 由服務(wù)器代碼寫入，
其他集合都是由統(tǒng)計(jì)腳本生成。

retention.register
========================
留存率統(tǒng)計(jì)用，新建帳號(hào)。
記錄新建帳號(hào)的創(chuàng)建日期。
有以下字段：
platform, 平臺(tái)名
account_id, 帳號(hào)
date, 注冊(cè)日期，字符串，格式：“2015-01-01”
例如： {platform: "baidu", account_id: "jinqing", date: "2015-09-20"}
索引 (platform, account_id), (date)
用于統(tǒng)計(jì)每日新增帳號(hào)數(shù)。

retention.login
==================
留存率統(tǒng)計(jì)用，帳號(hào)登錄記錄。
有以下字段：
date, 登錄日期
platform, 平臺(tái)名
account_id, 帳號(hào)
register_date, 帳號(hào)注冊(cè)日期
例如：{date: "2015-09-23", platform: "baidu", account_id: "jinqing", register_date: "2015-09-20"}
索引 (date, platform, account_id).

retention.result
===================
留存率結(jié)果。例如：
{date : "2015-09-01", register : 3344, 1 : 91.1, 2 : 82.2, 3 : 73.3, 4 : 64.4, 5 : 55.5, 6 : 46.6, 7 : 37.7, 14 : 14.0, 30 : 3.33}
{date : "2015-09-02", register : 3344, 1 : 91.1, 2 : 82.2, 3 : 73.3, 4 : 64.4, 5 : 55.5, 6 : 46.6, 7 : 37.7, 14 : 14.0, 30 : 3.33}
可用 mongoexport 導(dǎo)出為 csv 表格文件。
例如：
D:\mongodb\bin>mongoexport -h localhost -d mydb -c retention.result -f date,register,1,2,3,4,5,6,7,14,30 --csv -o d:\temp\retention.csv
其中
date: 注冊(cè)日期
register: 新注冊(cè)個(gè)數(shù)
1,2,...7,14,30: 第1日，2日，... 7日，14日，30日留存百分率

留存率統(tǒng)計(jì)腳本
--------------
linux下用crontab,
windows下用定時(shí)任務(wù),
每日凌晨 00:30 運(yùn)行統(tǒng)計(jì)腳本。

允許隔了幾天沒運(yùn)行，運(yùn)行時(shí)將從上次運(yùn)行處一直統(tǒng)計(jì)到當(dāng)天。
如果是首次運(yùn)行，則從 retention.register 集合的最早日期開始統(tǒng)計(jì)。
一天運(yùn)行多次也不會(huì)影響結(jié)果。
但是不能同時(shí)運(yùn)行多個(gè)實(shí)例。

需 mongo 客戶端。
可在 mongo 主機(jī)上運(yùn)行。

mongo my.mongo.host retention.js
生成結(jié)果在 mydb.retention.result 集合中，可用 mongoexport 導(dǎo)出為 csv 文件。

#!/bin/sh
# retention.sh
# 每日凌晨定時(shí)執(zhí)行，統(tǒng)計(jì)留存率。
# 需 mongo 客戶端。

# 以下需更改為實(shí)際目錄, 將在該目錄下運(yùn)行。
cd /home/jinq/retention/

# 以下地址應(yīng)該改為 mongod 服務(wù)器地址。
MONGODB=192.168.8.9

mongo ${MONGODB} retention.js >> log.txt

echo Mongo export retention result

mongoexport -h ${MONGODB} -d mydb -c retention.result \
  --sort '{"value.date" : 1}' \
  -f value.date,value.register,value.1,value.2,value.3,value.4,value.5,value.6,value.7,value.14,value.30 \
  --type=csv -o retention_tmp.csv

DATE=`date +%Y%m%d`
FILE=retention_${DATE}.csv

# csv替換列頭
echo 日期,注冊(cè)數(shù),1日,2日,3日,4日,5日,6日,7日,14日,30日 > ${FILE}
tail -n +2 retention_tmp.csv >> ${FILE}

echo Done ${FILE}!

// 留存率統(tǒng)計(jì)腳本
// 參考文檔：留存率統(tǒng)計(jì).txt
// Usage:
// mongo my.mongo.host retention.js

print(Date());
db = db.getSisterDB("mydb"); // use mydb

var startDate = getStartDate();
var endDate = formatDate(new Date());
print("Calculating retention rate of [" + startDate + ", " + endDate + ")

");
if (startDate < endDate) {
    insertDefaultResult(startDate);
    calcRegisterCount(startDate);
    calcRetention(startDate);
    print(Date());
    print("Done.");
} else {
    print("Do nothing.");
}

// Internal functions.

// 獲取統(tǒng)計(jì)開始日期，之前的已經(jīng)統(tǒng)計(jì)完成，無需重做。
// 返回字符串，格式："2015-01-01"
// 獲取 retention.result 的最大 date + 1天, 僅須處理該天及以后的數(shù)據(jù)。
// 如果是初次運(yùn)行，retention.result 為空，須讀取 retention.register 的最早日期作為開始。
function getStartDate() {
    var lastResultDate = getLastResultDate();
    if (null == lastResultDate) {
        return getFirstRegisterDate();
    }

    // 加一天
    return getNextDate(lastResultDate);
}

// 獲取最早的 retention.register 日期。
function getFirstRegisterDate() {
    var cursor = db.retention.register.find(
        {date : {$gt : "2015-09-01"}},  // 除去 null
        {_id : 0, date : 1}
    ).sort({date : 1}).limit(1);
    if (cursor.hasNext()) {
        return cursor.next().date;
    }
    return formatDate(new Date());
}

// 獲取 retention.result 中最后的 date 字段。
// 無date字段則返回null。
// 正常返回如："2015-01-01"
function getLastResultDate() {
    // _id 為日期串
    var cursor = db.retention.result.find(
        {}, {_id : 1}).sort({_id : -1}).limit(1);
    if (cursor.hasNext()) {
        return cursor.next()._id;
    }
    return null;
}

function add0(m) {
    return m < 10 ? '0' + m : m;
}

// Return likes: "2015-01-02"
function formatDate(date)
{
    var y = date.getFullYear();
    var m = date.getMonth() + 1;  // 1..12
    var d = date.getDate();
    return  y + '-' + add0(m) + '-' + add0(d);
}

// "2015-12-31" -> "2016-01-01"
function getNextDate(dateStr) {
    var dateObj = new Date(dateStr + " 00:00:00");
    var nextDayTime = dateObj.getTime() + 24 * 3600 * 1000;
    var nextDate = new Date(nextDayTime);
    return formatDate(nextDate);
}

assert(getNextDate("2015-12-31") == "2016-01-01");
assert(getNextDate("2015-01-01") == "2015-01-02");
assert(getNextDate("2015-01-31") == "2015-02-01");

// 插入缺省結(jié)果。
// 某些天無新注冊(cè)，mapreduce就不會(huì)生成該條結(jié)果，須強(qiáng)制插入。
function insertDefaultResult(startDateStr) {
    var docs = new Array();
    var endDateStr = formatDate(new Date());
    for (var dateStr = startDateStr;
        dateStr < endDateStr;
        dateStr = getNextDate(dateStr)) {
        docs.push({_id : dateStr, value : {date : dateStr, register : 0}});
    }  // for
    db.retention.result.insert(docs);
}

// 讀取 retention.register 集合，
// 計(jì)算每日新注冊(cè)量, 記錄于 retention.result.value.register 字段
// startDate is like: "2015-01-01"
function calcRegisterCount(startDate) {
    var mapFunction = function() {
        var key = this.date;
        var value = {date : key, register : 1};
        emit(key, value);
    };  // mapFunction

    var reduceFunction = function(key, values) {
        var reducedObject = {date : key, register : 0};
        values.forEach(
            function(value) {
                reducedObject.register += value.register;
            }
        )
        return reducedObject;
    };  // reduceFunction

    var endDate = formatDate(new Date());
    db.retention.register.mapReduce(mapFunction, reduceFunction,
        {
            query: {date: {$gte: startDate, $lt: endDate}},
            out: {merge: "retention.result"}
        }
    );  // mapReduce()
}  // function calcRegisterCount()

// 讀取 retention.login 集合，
// 計(jì)算留存率，保存于 retention.result 集合。
// startDate is like: "2015-01-01"
function calcRetention(startDate) {
    var mapFunction = function() {
        var key = this.register_date;
        var registerDateObj = new Date(this.register_date + " 00:00:00");
        var loginDateObj = new Date(this.date + " 00:00:00");
        var days = (loginDateObj - registerDateObj) / (24 * 3600 * 1000);
        var value = {date : key, register : 0};
        var field = days + "_count";  // like: 1_count
        value[field] = 1;
        emit(key, value);
    };  // mapFunction

    var reduceFunction = function(key, values) {
        var reducedObject = {date : key, register : 0};
        for (var i = 1; i <= 60; i++) {
            var field = i + "_count";
            reducedObject[field] = 0;
        }

        values.forEach(
            function(value) {
                reducedObject.register += value.register;
                for (var i = 1; i <= 60; i++) {
                    var field = i + "_count";  // like: 1_count
                    var count = value[field];
                    if (null != count) {
                        reducedObject[field] += count;
                    }  // if
                }  // for
            }  // function
        )  // values.forEach()
        return reducedObject;
    };  // reduceFunction()

    var finalizeFunction = function(key, reducedVal) {
        if (0 == reducedVal.register)
            return reducedVal;
        for (var i = 1; i <= 60; i++) {
            var field = i + "_count";  // 1_count
            var count = reducedVal[field];
            reducedVal[String(i)] = count * 100 / reducedVal.register;
        }
        return reducedVal;
    };  // finalizeFunction

    var endDate = formatDate(new Date());
    db.retention.login.mapReduce(mapFunction, reduceFunction,
        {
            query: {date: {$gte: startDate, $lt: endDate}},
            out: {reduce: "retention.result"},
            finalize: finalizeFunction,
        }
    );  // mapReduce()
}  // function calcRetention()

參考
-----

用戶留存率_百度百科
http://baike.baidu.com/link?url=28-agScaamT__jLEBdn5VW-a6CHRlf53bDUrVezkeaHd6TMhO0ULm_9JMmcOu541taQjWGe0JypERg2hIwJCAa

游戲玩家的留存率統(tǒng)計(jì)實(shí)現(xiàn) - 流子的專欄 - 博客頻道 - CSDN.NET
http://blog.csdn.net/jiangguilong2000/article/details/16119119

在Mongo數(shù)據(jù)庫(kù)里怎么統(tǒng)計(jì)留存率呢? - SegmentFault
http://segmentfault.com/q/1010000000652638

posted on 2015-11-10 17:22 金慶閱讀(632) 評(píng)論(0) 編輯收藏引用所屬分類: 2. 網(wǎng)游開發(fā)

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
【推薦】100%開源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: How are dtLinks created in NavMesh UE4 Blueprint Multiple Event BeginPlay 第9代游戲主機(jī) Canvas Scaler 的3種模式幀同步是否允許客戶端指定命令幀號(hào) rpc應(yīng)答太快造成請(qǐng)求超時(shí) 測(cè)試 tolua 例子 TestErrorStack lua變量缺少local造成unity死鎖 C# tolua 之間互傳 byte[] Unity使用異步grpc

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊(cè)

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜