duanpuchen3142 2017-05-26 07:36
浏览 76
已采纳

是否可以使用mgo驱动程序运行mongo复制集命令?

Is it possible to run replica set commands like rs.initiate() and rs.add() using mgo driver from a golang application?

If yes, how??

  • 写回答

2条回答 默认 最新

  • dongtaihui5131 2017-06-03 09:20
    关注

    Thanks to @alex-blex's answer which gave me the start. But this is what finally worked for me:

    session, err := mgo.Dial("rs1.example.net?connect=direct")
    if err != nil {
        panic(err)
    }
    defer session.Close()
    session.SetMode(mgo.Monotonic, true)
    
    config := bson.M{
        "_id": "my_replica_set",
        "members": []bson.M{
            {"_id": 0, "host": "rs1.example.net:27017"},
            {"_id": 1, "host": "rs2.example.net:27017", "priority": 2},
            {"_id": 2, "host": "rs3.example.net", "arbiterOnly": true},
        },
    }
    result := bson.M{}
    if err := session.Run(bson.M{"replSetInitiate": config}, &result); err != nil {
        panic(err)
    }
    

    Notice the following:

    1. ?connect=direct in the connection string.

      If not specified, the connection will timeout, probably because the replica set has not been initialized yet.

    2. session.SetMode(mgo.Monotonic, true)

      Session mode should be monotonic as the default session used by mgo is primary which performs all operations on primary. Since the replica set has not been initialized yet, there wont be a primary and the operation (in this case, replSetInitiate) will just timeout

    3. "_id": "my_replica_set" in the config

      For this to work, the mongo servers will have to be started with the replica set name my_replica_set. One way of doing that would be:

      mongod --replSet my_replica_set
      
    4. As per Mgo docs use session.Run() for commands on the "admin" database
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 关于IMageEnView 图标定位问题
  • ¥20 求解答(matlab)
  • ¥30 ffmpeg库使用过程中遇到的问题
  • ¥15 pyqt5 中python如何通过Qtwebchannel主动发消息给web前端
  • ¥15 关于HTML中title获取xml内容的问题
  • ¥15 fanuc机器人PRIO083数字信号未复原错误,如何解决?
  • ¥20 如何为现有电路板增加远程控制功能
  • ¥15 UE5打包失败,求解决
  • ¥15 请问STM32G431的CANOPEN协议函数怎么写
  • ¥15 graphpad prism 三因素重复测定报错