如何等待副本赶上主人

Question

有一个mongodb集群（1主2副本）

更新记录数量较多，本次使用BulkWrite，replicas追上master后需要调用下一次BulkWrite，需要确保replicas已经追上master了。使用 go.mongodb.org/mongo-driver/mongo

Answer 1

可以使用 writeconcern.WriteConcern 来“控制”写入传播。

WriteConcern 可以使用不同的 writeconcern.Option 创建。 writeconcern.W() 函数可用于创建一个 writeconcern.Option 来控制必须向多少个实例写入（或者更具体地说，写入操作将等待来自给定数量实例的确认）：

func W(w int) Option
W requests acknowledgement that write operations propagate to the specified number of mongod instances.

因此，首先您需要创建一个 writeconcern.WriteConcern，该 writeconcern.WriteConcern 已正确配置以等待您的案例中来自 2 个节点的确认（您有 1 个主节点和 2 个副本节点）：

wc := writeconcern.New(writeconcern.W(2))

您现在必须选择此写入关注的范围：它可能应用于整个mongo.Client, it may be applied on a mongo.Database or just applied on a mongo.Collection。

创建客户端、获取数据库或只是一个集合都有允许指定写关注的选项，所以这真的取决于您想要应用它的地方。

如果您只是希望此写入问题对某些更新产生影响，将其应用于您用来执行更新的 mongo.Collection 就足够了：

var client *mongo.Client // Initialize / connect client 

wc := writeconcern.New(writeconcern.W(2))
c := client.Database("<your db name>").
    Collection("<your collection name>",
        options.Collection().SetWriteConcern(wc))

现在，如果您使用此 c 集合来执行写入（更新），将使用/应用 wc 写入关注点，也就是说，每个写入操作都将等待写入传播到 2 个实例。

如果您要在 mongo.Client 上应用 wc 写入音乐会，那么如果您将它应用到 mongo.Database，那么它将成为您对该数据库所做的所有操作的默认设置。当然可以覆盖默认值，就像我们在上面的示例中对 c 集合应用 wc 的方式。

如何等待副本赶上主人

How to wait while replicas are caught up master

go

mongodb

mongo-go