Golang MongoDB 聚合查询返回百级文档时出现空游标问题求助

常见触发原因 #

• 默认批次返回阈值触发逻辑遗漏：MongoDB服务端默认单次查询返回的第一批结果上限为101条文档，或总大小超过1MB时自动拆分批次。如果你的代码仅判断第一批返回的结果长度，没有完整迭代游标所有批次，就会误以为游标为空。优先用官方驱动提供的cursor.All()方法自动处理多批次拉取，不需要手动处理迭代逻辑。
• 查询超时配置不合理：如果给查询Context设置的超时时间过短，或者在FindOptions中设置的MaxTimeMS小于大批量查询需要的执行时间，服务端会提前终止查询，返回无效游标。可以根据你的数据量大小，适当调高超时阈值，单集合查询1000条以内建议设置10秒以上超时。
• 游标自动回收触发：MongoDB默认会对10分钟内没有进行任何操作的游标自动销毁，如果你在游标迭代过程中插入了其他耗时逻辑，导致游标长时间无访问，就会出现后续拉取不到数据的情况。如果确实需要长时间持有游标，可以设置SetNoCursorTimeout(true)，但必须手动调用cursor.Close()释放资源，避免服务端游标泄漏。
• 驱动版本Bug：1.0.x及更早版本的官方mongo-go-driver存在多批次游标处理的已知问题，会出现超过101条数据时拉取失败的情况，建议升级到v1.8.0以上的稳定版本。

正确查询示例代码 #

package main

import (
	"context"
	"log"
	"time"

	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

type YourModel struct {
	// 你的结构体字段，注意bson标签映射正确
	ID string `bson:"_id"`
	// 其他字段...
}

func main() {
	// 建立客户端连接逻辑省略
	var collection *mongo.Collection

	// 设置合理的查询上下文超时
	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
	defer cancel()

	// 配置查询选项
	findOpts := options.Find().
		SetBatchSize(200). // 按需调整批次大小，避免频繁分批拉取
		SetMaxTime(20 * time.Second) // 设置查询最大执行时间

	// 执行查询
	cursor, err := collection.Find(ctx, bson.M{"your_filter_field": "filter_value"}, findOpts)
	if err != nil {
		log.Fatalf("查询发起失败: %v", err)
	}
	defer cursor.Close(ctx) // 务必延迟关闭游标释放资源

	// 自动迭代所有批次拉取数据
	var results []YourModel
	if err = cursor.All(ctx, &results); err != nil {
		log.Fatalf("游标数据解析失败: %v", err)
	}

	log.Printf("共查询到%d条符合条件的文档", len(results))
}

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