聚合管道返回错误结果与 CLI

Question

我在 mongo 中有一个集合，我在上面运行以下查询db.feeds.aggregate({"$match":{createdat:"20190203"}}, {"$group": {_id: {"type": "$type"}, total: {$sum: 1} }},{"$project":   {"type": "$_id.type", "tot": "$total", "_id": 0} }   )它按预期工作并返回，{ "type" : "f", "tot" : 1 }{ "type" : "ebm", "tot" : 1 }{ "type" : "b", "tot" : 3 }但是，当我尝试在 Golang 中复制管道时，如下所示：    pipeline := []bson.M{    // match    {"$match": bson.M{"createdat": when}},    // group    {"$group": bson.M{        "_id":        bson.M{"type": "$type"}, // "$fieldname" - return the field        "TotalFeeds": bson.M{"$sum": 1}}},    // project    {"$project": bson.M{"type": "$_id.type", // project selects subset of fields        "TotalFeeds": "$TotalFeeds", // rename fiedls        "_id":        0}},           // 0 means not show _id}返回的计数为 0。map[$match:map[createdat:20190203]] map[$group:map[TotalFeeds:map[$sum:1] _id:map[type:$type]]] map[$project:map[type:$_id.type TotalFeeds:$TotalFeeds _id:0]]]{f 0  }{ebm 0  }{b 0  }[{f 0  } {ebm 0  } {b 0  }]下面是我在 Golang 中使用的整个函数：func CountFeeds(when string) Feeds {    ctx, _ := context.WithTimeout(context.Background(), 60*time.Second)    pipeline := []bson.M{        // match        {"$match": bson.M{"createdat": when}},        // group        {"$group": bson.M{            "_id":        bson.M{"type": "$type"}, // "$fieldname" - return the field            "TotalFeeds": bson.M{"$sum": 1}}},        // project        {"$project": bson.M{"type": "$_id.type", // project select subset of fields            "TotalFeeds": "$TotalFeeds", // rename fiedls            "_id":        0}},           // 0 means not show _id    }    fmt.Println(pipeline)    curs, err := db.Collection("feeds").Aggregate(ctx, pipeline)    utilities.Catch(err)    defer curs.Close(ctx)    element := Feeds{}    e := []Feeds{}    for curs.Next(ctx) {        err := curs.Decode(&element)        fmt.Println(element)        utilities.Catch(err)        e = append(e, element)    }    fmt.Println(e)    return element}

Answer 1

首先，使用bson.D{}而不是bson.M{}。这是因为bson.D{}应该在顺序很重要的情况下使用，例如 MongoDB 命令。

您还可以将整个管道封装在mongo.Pipeline中。例如：

pipeline := mongo.Pipeline{

    {{"$match", bson.D{{"createdata", 10}}}},

    {{"$group", bson.D{

        {"_id",        bson.D{{"type", "$type"}}}, 

        {"TotalFeeds", bson.D{{"$sum", 1}}},

    }}},

    {{"$project", bson.D{

        {"type", "$_id.type"}, 

        {"TotalFeeds", "$TotalFeeds"}, 

        {"_id", 0}},

    }},          

}

检查你的Feeds{}结构映射。确保您指定映射bson，即：

type Feeds struct {

    Type string `bson:"type"`

    TotalFeeds int `bson:"TotalFeeds"`

}

或者，在您的投影阶段，$project您对字段使用一致的大小写。例如，指定所有小写type和/totalfeeds或所有大写Type和TotalFeeds。

pipeline := mongo.Pipeline{

    {{"$match", bson.D{{"createdata", 10}}}},

    {{"$group", bson.D{

        {"_id",        bson.D{{"type", "$type"}}}, 

        {"totalfeeds", bson.D{{"$sum", 1}}},

    }}},

    {{"$project", bson.D{

        {"type", "$_id.type"}, 

        {"totalfeeds", "$totalfeeds"}, 

        {"_id", 0}},

    }},      

}

然后你不必bson在结构中指定映射：

type MyStruct struct {

    Type string 

    Total int

}

因此，要么在结构中使用一致的字段名称大小写，要么显式提供映射bson。