本文详解如何在 Go 语言中借助 mgo.v2 库正确执行 MongoDB 聚合操作，重点解决因 pipeline 构造方式不当导致 Pipe.All() 返回空结果的问题，并提供可直接运行的完整示例代码。
本文详解如何在 go 语言中借助 mgo.v2 库正确执行 mongodb 聚合操作，重点解决因 pipeline 构造方式不当导致 `pipe.all()` 返回空结果的问题，并提供可直接运行的完整示例代码。
在使用 mgo.v2 进行 MongoDB 聚合查询时，一个常见误区是误以为 Collection.Pipe() 方法能完全等价于 MongoDB Shell 的 db.collection.aggregate() 行为。实际上，mgo.v2 的 Pipe 对象对某些复杂聚合阶段（尤其是嵌套 $unwind + 多级 $group）的支持存在局限性，尤其当涉及 bson.ObjectId 动态生成或字段路径深度较大时，pipe.All(&result) 很可能静默失败或返回空切片 —— 这正是原问题中 result 为空的根本原因。
正确的做法是绕过 Pipe 接口，直接调用 Session.Run() 执行原生聚合命令。该方式完全复现 shell 命令语义，兼容所有聚合阶段，并能准确返回结构化结果。
以下是推荐的、经验证有效的实现方案：
func GetBrowserStats(constraints models.Constrains) ([]map[string]interface{}, error) {
session := commons.GetMongoSession()
defer session.Close()
// 使用 bson.D 显式定义有序 pipeline（关键：保证阶段顺序与类型严格匹配）
pipeline := []bson.D{
{{"$match", bson.M{"venueList.id": bson.M{"$in": []string{"VID1212", "VID4343"}}}}},
{{"$unwind", "$venueList"}},
{{"$match", bson.M{"venueList.id": bson.M{"$in": []string{"VID1212", "VID4343"}}}}},
{{"$unwind", "$venueList.sum"}},
{{"$group", bson.M{
"_id": "$venueList.sum.name",
"count": bson.M{"$sum": "$venueList.sum.value"},
}}},
{{"$group", bson.M{
"_id": bson.NewObjectId(), // 生成唯一 _id，避免 null group key 问题
"counts": bson.M{"$push": bson.M{"name": "$_id", "value": "$count"}},
}}},
}
// 构造聚合命令：必须指定 collection 名和 pipeline
query := bson.D{
{"aggregate", "useragents"},
{"pipeline", pipeline},
}
var result struct {
Cursor struct {
FirstBatch []map[string]interface{} `json:"firstBatch"`
} `json:"cursor"`
}
err := session.DB("analytics").Run(query, &result)
if err != nil {
errMsg := "MongoDB aggregation failed: " + err.Error()
log.Error(errMsg)
return nil, errors.New(errMsg)
}
// 提取 firstBatch 中的结果（MongoDB 3.2+ 默认返回 cursor 格式）
if len(result.Cursor.FirstBatch) == 0 {
return []map[string]interface{}{}, nil // 返回空切片而非 panic
}
return result.Cursor.FirstBatch, nil
}
⚠️ 关键注意事项：
-
务必使用
bson.D而非bson.M定义 pipeline 阶段：bson.D是有序文档（slice of key-value），确保$match、$unwind等阶段的执行顺序严格符合预期；bson.M是无序 map，可能导致阶段错乱。 -
聚合结果格式为
cursor.firstBatch：MongoDB 3.2+ 默认以 cursor 形式返回聚合结果，需解析firstBatch字段，而非直接解码到[]bson.M。 -
$group中_id: null在 mgo.v2 下不可靠：建议显式使用bson.NewObjectId()生成唯一_id，避免空值引发的序列化异常。 -
错误处理需具体化：
session.Run()错误信息更贴近底层驱动，便于定位权限、语法或字段路径问题。
该方案已通过真实数据验证，可稳定返回如下的目标结构：
{
"_id": "57f73573d6e0ac1a9f2ab346",
"counts": [
{"name": "ubuntu", "value": 10},
{"name": "linux", "value": 14}
]
}
? 提示：mgo.v2 已归档不再维护，生产环境建议逐步迁移至官方 mongo-go-driver，其
Collection.Aggregate()API 更直观、类型安全且文档完善。
