登录
首页 >  Golang >  Go问答

如何编写mongo管道

来源:stackoverflow

时间:2024-04-11 14:03:35 492浏览 收藏

亲爱的编程学习爱好者,如果你点开了这篇文章,说明你对《如何编写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.Dbson.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学习网公众号!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>