如何编写mongo管道

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《如何编写mongo管道》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

我正在尝试编写一个 mongo 管道来选择 mongodb 文档，如下面的函数所示。 mongo.pipeline 显示“复合文字中缺少类型”。 我试图根据最高容量聚合文档中与 nftype 匹配的所有 ipv4addresses。我正在使用 mongo 驱动程序。 谁能帮我解决 mongo.pipeline 问题。

func (m *nfinstancedataaccess) findnfinstanceinfousingtacwithcapacity(preferrednfinstances string, tac string) ([]doc, bool) {

    var nfinstance []doc
    pipeline := mongo.pipeline{{{"$match", bson.m{{"nftype", preferrednfinstances}}}},
        {{"$unwind", "$ipv4addresses"}},
        {{"$group", bson.m{
            {"_id": "$capacity"},
            {"ipv4addresses": bson.m{
                {"$addtoset", "$ipv4addresses"},
            }},
        }}},
        {{"$sort", bson.m{
            {"_id", 1},
        }}},
        {{"$limit", 1}},
    }
    cursor, err := db.collection(collection).aggregate(context.background(), pipeline)
    defer cursor.close(context.background())

    err = cursor.all(ctx, &nfinstance)
    if err != nil {
        log.printf("unable to perform nrf discovery search: %s", err.error())
    }
    if err := cursor.err(); err != nil {
        log.printf("cursor error in nrf discovery search: %s", err.error())
    }
    return nfinstance, true
}

下面的管道使用 mongo 命令行工作。我想要它的 bson.m 形式。任何帮助。

db.nnfdb.aggregate([
  {
    "$match": {
      "nfType": "AMF"
    }
  },
  {
    "$unwind": "$ipv4Addresses"
  },
  {
    $group: {
      "_id": "$capacity",
      "ipv4Addresses": {
        "$addToSet": "$ipv4Addresses"
      }
    }
  },
  {
    "$sort": {
      "_id": 1
    }
  },
  {
    "$limit": 1
  }
])

解决方案

mongo.pipeline 显示“复合文字中缺少类型”

您的聚合管道混合了 bson.D 和 bson.M 的语法。例如，bson.d 是：

bson.d{{ "a", 1 }, { "b", true }}

而bson.m如下：

bson.m{ "a": 1, "b": true }

请注意括号 { , } 的数量以及逗号和分号。

对于有时顺序很重要的 mongodb 聚合管道，更安全，建议使用 bson.d 而不是 bson.m。利用这些知识，下面是您提供的修复后的聚合管道。

pipeline := mongo.pipeline{
    {{"$match", bson.d{{"nftype", preferrednfinstances}}}},
    {{"$unwind", "$ipv4addresses"}},
    {{"$group", bson.d{
        {"_id", "$capacity"},
        {"ipv4addresses", bson.d{
            {"$addtoset", "$ipv4addresses"},
        }},
    }}},
    {{"$sort", bson.d{
        {"_id", 1},
    }}},
    {{"$limit", 1}},
}

或者，如果您想使用 bson.m，请参阅下面的示例：

pipeline := []bson.M{
    bson.M{"$match": bson.M{"nfType": preferredNfInstances}},
    bson.M{"$unwind": "$ipv4Addresses"},
    bson.M{"$group": bson.M{
        "_id": "$capacity",
        "ipv4Addresses": bson.M{
            "$addToSet": "$ipv4Addresses",
        },
    }},
    bson.M{"$sort": bson.M{
        "_id": 1,
    }},
    bson.M{"$limit": 1},
}

本篇关于《如何编写mongo管道》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！