需要光标选项

Question

我在我的项目中使用 Go 和 MongoDB。我用过db.collection.aggregate([{$match:{}},{$lookup:{}},{$addFields:{}}])它在 MongoDB 中运行良好，但是当我在 Go 中使用管道时，出现以下错误The 'cursor' option is required, except for aggregate with the explain argument去代码是matchStage:=bson.M{"$match":bson.M{}}pipeline := collection.Pipe([]bson.M{matchStage})    err = pipeline.All(&resp)

Answer 1

这不是你应该在 Go 中实现 Mongo-Aggregation 查询的方式。

它应该是格式

cursor, err := collection.Aggregate(

        ctx,

        mongo.Pipeline{<PIPELINE-STAGES>},

        options.Aggregate().SetAllowDiskUse(true),

        )

因此，您的代码应该是：

ctx, _ = context.WithTimeout(context.Background(), 2*time.Second)

matchStage := bson.D{

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

    }

lookupStage := bson.D{

        {"from", ""},

        {"let": bson.D{{}}},

        {"pipeline": bson.A{}},

        {"as": ""},

    }

addFieldsStage := bson.D{

        {"$addFields", bson.D{}},

    }

cursor, err := collection.Aggregate(

    ctx,

    mongo.Pipeline{matchStage, lookupStage, addFieldsStage},

    options.Aggregate().SetAllowDiskUse(true),  // Mongo-Aggregate options if any

    )

if err != nil {

    panic(err)

}

for cursor.Next(ctx) {

    var cursorResult bson.M

    err := cursor.Decode(&cursorResult)  // I world recommend to decode it using a struct instead

    if err != nil {

        panic(err)

    }

    fmt.Printf("Decoded Cursor: %v", cursorResult)

}

err = cursor.Close(ctx)

if err != nil {

  panic(err)

}

注意：我没有在本地测试过代码。因此，如果出现错误，请告诉我。