如何在 change stream watch api (mongo-go-driver)

Question

我正在使用传递 batchSize changestreamopt.BatchSize。但这不起作用发生此错误：BSON field '$changeStream.batchSize' is an unknown field示例 API 调用// coll is  *mongo.Collection// ctx is contextcur, err := coll.Watch(ctx, nil, changestreamopt.BatchSize(1000))

Answer 1

这看起来像是当前mongo-go-driver(v0.0.16) 中的错误，其中batchSize选项被传递到$changestream管道阶段而不是光标。

代码change_stream.go#L66-L73似乎只用于maxAwaitTime光标。