我正在嘗試將此函數(shù)從 mapreduce 轉(zhuǎn)換為聚合。上述函數(shù)的結(jié)果將是[{pending 1}]。當(dāng)我運(yùn)行我的匹配組時(shí)，我[{pending 0}]從下面的代碼中得到：? mat := bson.M{? ? ? ? ? ? "$match": bson.M{"device_id": devId},? ? }? ? grp := bson.M{? ? ? ? ? ? "$group": bson.M{? ? ? ? ? ? ? ? ? ? "_id": "$status",? ? ? ? ? ? ? ? ? ? "count": bson.M{? ? ? ? ? ? ? ? ? ? ? ? ? ? "$sum": 1,? ? ? ? ? ? ? ? ? ? },? ? ? ? ? ? },? ? }? ? pipe := c.Pipe([]bson.M{mat,grp})? ? pipe.One(&result)但我認(rèn)為 mongo shell 中的命令也一樣[{pending 1}]。db.getCollection("auth_sets").aggregate([{? ? $match: {? ? ? ? device_id:"5c79601d152ece00012f5831"? ? }},{? ? $group: {? ? ? ? _id:"$status",? ? ? ? count: {? ? ? ? ? ? $sum: 1? ? ? ? }? ? ?}},]);我怎樣才能得到它，以便我的管道返回[{pending 1}]？我正在更改它，以便我可以使用 Mongo Atlas 不允許 mapreduce。
1 回答
墨色風(fēng)雨
TA貢獻(xiàn)1853條經(jīng)驗(yàn) 獲得超6個(gè)贊
您的mgo查詢結(jié)構(gòu)沒(méi)問(wèn)題，問(wèn)題是字段名稱count。該模型期望Value：
var result []struct {
Status string `bson:"_id"`
Value int
}
所以把$group舞臺(tái)改成這樣：
grp := bson.M{
"$group": bson.M{
"_id": "$status",
"value": bson.M{ // Note lowercased "value"!
"$sum": 1,
},
},
}
它應(yīng)該有效?；蛘?，如果可以，請(qǐng)更改模型：
var result []struct {
Status string `bson:"_id"`
Value int `bson:"count"`
}
只有其中一個(gè)需要更改，才能與另一個(gè)保持一致。
最后一件事：如果您使用Query.One()，則result不能是切片（One()恰好需要一個(gè)文檔）。
result如果您使用 eg ，請(qǐng)使用切片類(lèi)型Query.All()。
因此，如果您要使用Query.One()，請(qǐng)使用結(jié)果：
var result struct {
Status string `bson:"_id"`
Value int `bson:"count"`
}
另外Query.One()并Query.All()返回錯(cuò)誤，請(qǐng)檢查它！
- 1 回答
- 0 關(guān)注
- 163 瀏覽
添加回答
舉報(bào)
0/150
提交
取消