如何在 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 context

cur, err := coll.Watch(ctx, nil, changestreamopt.BatchSize(1000))

Answer 1

这看起来像是当前mongo-go-driver(v0.0.16) 中的错误，其中batchSize选项被传递到$changestream管道阶段而不是光标。代码change_stream.go#L66-L73似乎只用于maxAwaitTime光标。