談?wù)勔恍╆P(guān)于mgo的用法

李世贊發(fā)布于2019-06-26 17:15 / 1086人閱讀

摘要：在這里談一談實(shí)踐過程中遇到的問題，基礎(chǔ)的用法不再說明了，可以自行百度。一般傳入的參數(shù)為。當(dāng)然中的聚合命令不止這些，用法大同小異如果要實(shí)現(xiàn)一些高級功能，的基本命令滿足不了你，可能就要使用這個(gè)了。

前言

最近在項(xiàng)目中使用mongodb進(jìn)行簡單的數(shù)據(jù)分析，在使用mongodb驅(qū)動(dòng)mgo時(shí)遇到一些問題，比如在mongodb中執(zhí)行命令成功，到了mgo中就執(zhí)行失敗。在這里談一談實(shí)踐過程中遇到的問題，基礎(chǔ)的用法不再說明了，可以自行百度。

使用 查找(Find)

這個(gè)估計(jì)是mongodb里用的最多的了吧，mgo中使用Find(query interface{})，query參數(shù)一般傳入[]bson.M。下面給個(gè)例子：

m := bson.M{
        "CurTimestamp": bson.M{
            "$gte": start,
            "$lte": end,
        },
        "Account":    account,
        "ToNodeType": "cloud",
    }
    session.DB("db").C("collect").Find(m).Count()

這里查找時(shí)間戳內(nèi)，賬號(hào)為account，節(jié)點(diǎn)類型為cloud的數(shù)據(jù)并統(tǒng)計(jì)個(gè)數(shù)。

聚合管道（Aggregation Pipeline）

聚合管道在mgo中為Pipe(pipeline interface{}) ，這個(gè)和bash中使用的管道很像，數(shù)據(jù)可以被層層處理。一般傳入的參數(shù)為[]bson.M。這個(gè)[]bson.M里如果還有嵌套則還要使用[]bson.M(剛開始使用就被坑了一下)。比如這里首先匹配節(jié)點(diǎn)類型和賬號(hào)，時(shí)間戳在一段時(shí)間內(nèi)，然后根據(jù)名字分組統(tǒng)計(jì)數(shù)量，最后排序取最前面的三個(gè)。

   //這個(gè)就可以傳入Pipe
   m := []bson.M{
        {"$match": bson.M{"NodeType": "cloud", "Account": account, "CurTimestamp": bson.M{"$gte": start, "$lte": end}}},
        {"$group": bson.M{"_id": "$TagName", "count": bson.M{"$sum": 1}}},
        {"$sort": bson.M{"count": -1}},
        {"$limit": 3},
    }
    //這里就可以取到輸出的數(shù)據(jù)
    var values []result
    session.DB("db").C("collect").Pipe(m).All(&values)

數(shù)據(jù)是一層一層過濾下來的。當(dāng)然mongodb中的聚合命令不止這些，用法大同小異

MapReduce

如果要實(shí)現(xiàn)一些高級功能，mongodb的基本命令滿足不了你，可能就要使用這個(gè)了。mongodb中要實(shí)現(xiàn)MapReduce就要實(shí)現(xiàn)Map函數(shù)和Reduce函數(shù)，Map函數(shù)調(diào)用emit將key和value傳給Reduce函數(shù)處理。這里給的例子首先計(jì)時(shí)間戳在哪個(gè)時(shí)間范圍內(nèi)，然后累加這個(gè)值，js不是很精通，寫的不好請見諒。

m := new(mgo.MapReduce)
    m.Map = `function() { var date = new Date();
    date.setTime(this.CurTimestamp / 1000);
    var hour = date.getHours();
    if((hour >= 6) && (hour <= 11)) {
        result.morning++;
    }else if((hour >= 12) && (hour <= 18)){
        result.afternoon ++;
    }else if((hour >= 19) && (hour <= 23)) {
        result.night ++;
    }else{
        result.am ++;
    }
    emit(this.Account, {});}`
    m.Reduce = `function() {return result;}`
    m.Scope = bson.M{
        "result": bson.M{
            "morning":   0,
            "afternoon": 0,
            "night":     0,
            "am":        0,
        },
    }
    var value []timeResult
    session.DB("db").C("collect").Find().MapReduce(m, &value)

這里的map函數(shù)負(fù)責(zé)計(jì)算時(shí)間戳范圍，result是引入的外部變量。這里就可以計(jì)算出這個(gè)賬號(hào)產(chǎn)生數(shù)據(jù)的時(shí)間范圍統(tǒng)計(jì)。

結(jié)語

其實(shí)用多了以后就基本能熟練使用了，重要還是了解mogodb命令的使用。