import "github.com/globalsign/mgo"job := &mgo.MapReduce{ Map: "function() { emit(this.name, 1) }", Reduce: "function(key, values) { return Array.sum(values) }", Out: "res",}_, err = c.Find(nil).MapReduce(job, nil)如何將“查詢”添加到上面的 golang mgo mapreduce ？參考：https://docs.mongodb.com/manual/core/map-reduce/ https://godoc.org/github.com/globalsign/mgo#MapReduce
2 回答
茅侃侃
TA貢獻(xiàn)1842條經(jīng)驗(yàn) 獲得超22個(gè)贊
設(shè)法通過(guò) MongoDb 官方 godriver 完成此任務(wù)
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
par := bson.D{
{"mapreduce", "audit"},
{"map", " function() { emit( this.name , 1 ); }"},
{"reduce", "function(key, arr) { return Array.sum(arr); }"},
{"out", "mr3"},
{"query", bson.D{{"status", "SUCCESS"}}},
}
sr := db.RunCommand(nil, par)
暮色呼如
TA貢獻(xiàn)1853條經(jīng)驗(yàn) 獲得超9個(gè)贊
MapReduce是 Find 返回的 Query 結(jié)構(gòu)的函數(shù)。因此，為了將 MapReduce 應(yīng)用于查詢結(jié)果，只需將查詢文檔添加到 find 函數(shù)中即可：
c.Find(query).MapReduce(job,result)
- 2 回答
- 0 關(guān)注
- 177 瀏覽
添加回答
舉報(bào)
0/150
提交
取消