如何在Go中运行非BSON格式的MongoDB聚合管道？

你遇到的核心问题是Mongo Compass导出的聚合管道采用Mongo Shell的JavaScript对象语法，而非严格JSON，导致标准json.Unmarshal无法解析。以下是两种无需修改管道内容、无需重新编译代码的可行方案：

方案一：文本预处理+Mongo扩展JSON解析 #

通过简单的正则替换将Compass格式转换为Mongo支持的扩展JSON，再用官方驱动的bson.UnmarshalExtJSON解析，无需额外依赖：

import (
    "regexp"
    "go.mongodb.org/mongo-driver/bson"
)

// parseCompassPipeline 将Compass导出的管道文本解析为[]bson.M
func parseCompassPipeline(pipelineText []byte) ([]bson.M, error) {
    // 给无引号的属性名添加双引号（匹配$开头或字母开头的合法键名）
    reKey := regexp.MustCompile(`(\$?[a-zA-Z_][a-zA-Z0-9_]*):`)
    processed := reKey.ReplaceAll(pipelineText, []byte(`"$1":`))

    // 替换ISODate为扩展JSON格式
    reISODate := regexp.MustCompile(`ISODate\("([^"]+)"\)`)
    processed = reISODate.ReplaceAll(processed, []byte(`{"$date": "$1"}`))

    // 替换ObjectId为扩展JSON格式
    reObjectId := regexp.MustCompile(`ObjectId\("([^"]+)"\)`)
    processed = reObjectId.ReplaceAll(processed, []byte(`{"$oid": "$1"}`))

    // 用扩展JSON解析为BSON结构
    var pipeline []bson.M
    err := bson.UnmarshalExtJSON(processed, true, &pipeline)
    return pipeline, err
}

使用方式：读取Compass导出的管道文件后，调用该函数得到[]bson.M，再传入collection.Aggregate即可。

优缺点：轻量无额外依赖，但正则替换可能存在边缘场景（比如字符串内容中包含类似键名的文本），适合大多数常规聚合管道。

方案二：通过JS引擎解析Mongo Shell语法 #

使用Go的JavaScript引擎goja直接解析Compass导出的管道文本，完美兼容Mongo Shell的函数语法（如ISODate、ObjectId）：

首先安装依赖：

go get github.com/dop251/goja

然后实现解析函数：

import (
    "github.com/dop251/goja"
    "go.mongodb.org/mongo-driver/bson"
)

// parseCompassPipelineJS 通过JS引擎解析Compass管道文本
func parseCompassPipelineJS(pipelineText string) ([]bson.M, error) {
    vm := goja.New()

    // 模拟Mongo Shell的全局函数，转换为Mongo扩展JSON格式
    vm.Set("ISODate", func(call goja.FunctionCall) goja.Value {
        dateStr := call.Argument(0).String()
        return vm.ToValue(map[string]string{"$date": dateStr})
    })
    vm.Set("ObjectId", func(call goja.FunctionCall) goja.Value {
        oidStr := call.Argument(0).String()
        return vm.ToValue(map[string]string{"$oid": oidStr})
    })
    // 如需支持其他函数（如NumberLong），可在此添加对应实现

    // 执行管道文本，解析为JS数组
    script := "pipeline = " + pipelineText
    if _, err := vm.RunString(script); err != nil {
        return nil, err
    }

    // 将JS对象转换为Go的[]bson.M
    var pipeline []bson.M
    if err := vm.ExportTo(vm.Get("pipeline"), &pipeline); err != nil {
        return nil, err
    }
    return pipeline, nil
}

优缺点：兼容性极强，能处理复杂的Mongo Shell语法，但引入了JS引擎依赖，编译后的二进制体积会略有增加。

注意事项 #

• 确保Compass导出的管道文本是完整的数组格式（如[{$match: {...}}, {$group: {...}}]）
• 若管道中包含其他Mongo Shell专属函数，可在方案二中添加对应的转换逻辑

内容的提问来源于stack exchange，提问作者Pete McKinney