mongodb - 如何在更改流监视 api（mongo-go-driver）中设置 batchSize？

Question

我正在使用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光标。

我已经向 MongoDB Go 驱动程序团队开了一张GODRIVER-591的票。