mongo-go-driver 聚合调用总是返回错误

Question

我正在尝试使用 mongo-go-driver(Golang 的 MongoDB 团队驱动程序(进行聚合，但我看不到我在这里做错了什么：

// group
group, e := bson.ParseExtJSONObject(`
{
"$group": {
"_id":{
"ProductCode":"$ProductCode",
"Dir":"$Dir",
"WharehouseID":"$WharehouseID"
}
}
}
`)

cursor, e := myCollection.Aggregate(
context.Background(),
group,
)
// e output: "(Location40324) Unrecognized pipeline stage name: '_id'"

这是一个 mongodb 错误，但如果我在 mongodb 本机客户端中执行此查询，我会得到结果并且不会发生错误。

Answer 1

除了解析一串MongoDB扩展JSON来构建聚合管道之外，您还可以构造一个bson。数组对象(类型化(：

例如：

pipeline := bson.NewArray(
bson.VC.DocumentFromElements(
bson.EC.SubDocumentFromElements(
"$group",
bson.EC.SubDocumentFromElements(
"_id",
bson.EC.String("ProductCode","$ProductCode"),
bson.EC.String("Dir","$Dir"),
bson.EC.String("WharehouseID","$WharehouseID"),
),
),
),
)
cursor, err := collection.Aggregate(context.Background(), pipeline)

上面的代码片段与当前的 mongo-go-driver 版本 0.0.12 兼容

Answer 2

我明白了！

我犯了两个错误：

1 - 我必须解析 JSON 对象数组

2 - 关闭"'"之前没有新行

这是工作示例：

group, e := bson.ParseExtJSONArray(`[{
"$group": {
"_id":{
"ProductCode":"$ProductCode",
"Dir":"$Dir",
"WharehouseID":"$WharehouseID"
}
}
}]`)
cursor, e := myCollection.Aggregate(
context.Background(),
group,
)