Как установить batchSize в api потока изменений (mongo-go-driver)?

Я передаю 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))
Источник

1 ответ

Решение

Это похоже на ошибку в текущем mongo-go-driver (v0.0.16) где batchSize опция передается в $changestream этап конвейера вместо курсора.

Код change_stream.go # L66-L73, кажется, использует только maxAwaitTime к курсору.

Я открыл билет GODRIVER-591 с командой водителей MongoDB Go.

Источник
Другие вопросы по тегам