Golang是否支持将MongoDB $merge操作指向副本集从节点？

文档内容详解 #

1. $merge的读写节点分配逻辑 #

$merge作为聚合管道的最终阶段，操作被拆分为读、写两个独立环节：

• 读取源集合数据完成聚合计算的读操作，会被路由到副本集的从节点执行，目的是分散主节点的读负载；
• 将聚合结果写入目标集合的写操作，只会在副本集的主节点执行——这是因为MongoDB副本集仅主节点具备写权限，以此保证数据一致性。

2. 驱动版本的支持限制 #

并非所有MongoDB驱动都实现了$merge读操作路由到从节点的功能，早期版本驱动可能会将$merge的全部操作都发送到主节点。只有更新后的驱动版本才支持这种读写拆分的路由策略，需要对照所用驱动的版本文档，确认是否包含该特性。

Golang驱动的支持情况 #

MongoDB官方Golang驱动（go.mongodb.org/mongo-driver）从v1.4.0版本开始，支持将$merge的读操作指向副本集从节点。

• 实现方式：创建客户端时需配置**读偏好（ReadPreference）**为secondary或secondaryPreferred，驱动会自动完成读操作到从节点、写操作到主节点的路由。
• 示例代码：

import (
    "context"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
    "go.mongodb.org/mongo-driver/mongo/readpref"
)

func main() {
    // 配置客户端，设置读偏好为优先从从节点读取
    clientOpts := options.Client().
        ApplyURI("mongodb://replica-node1:27017,replica-node2:27017,replica-node3:27017/?replicaSet=rs0").
        SetReadPreference(readpref.SecondaryPreferred())

    client, err := mongo.Connect(context.TODO(), clientOpts)
    if err != nil {
        panic(err)
    }
    defer client.Disconnect(context.TODO())

    // 执行包含$merge的聚合管道
    coll := client.Database("test").Collection("source")
    pipeline := mongo.Pipeline{
        // 自定义聚合阶段...
        {{"$merge", bson.D{{"into", "target"}}}},
    }
    _, err = coll.Aggregate(context.TODO(), pipeline)
    if err != nil {
        panic(err)
    }
}

内容的提问来源于stack exchange，提问作者Neha