使用下面的 MongoDB Go 驱动程序 mgo 代码 sn-p 连接到 MongoDB Atlas 工作,使用您的示例数据:
import (
"gopkg.in/mgo.v2"
"crypto/tls"
"net"
)
tlsConfig := &tls.Config{}
dialInfo := &mgo.DialInfo{
Addrs: []string{"prefix1.mongodb.net:27017",
"prefix2.mongodb.net:27017",
"prefix3.mongodb.net:27017"},
Database: "authDatabaseName",
Username: "user",
Password: "pass",
}
dialInfo.DialServer = func(addr *mgo.ServerAddr) (net.Conn, error) {
conn, err := tls.Dial("tcp", addr.String(), tlsConfig)
return conn, err
}
session, err := mgo.DialWithInfo(dialInfo)
请注意,您也可以仅指定一个副本集成员作为种子。例如:
Addrs: []string{"prefix2.mongodb.net:27017"}
另见:
更新:
您还可以使用ParseURL() 方法来解析 MongoDB Atlas URI 字符串。但是,目前此方法不支持 SSL (mgo.V2 PR:304)
解决方法是在解析之前取出ssl=true 行。
//URI without ssl=true
var mongoURI = "mongodb://username:password@prefix1.mongodb.net,prefix2.mongodb.net,prefix3.mongodb.net/dbName?replicaSet=replName&authSource=admin"
dialInfo, err := mgo.ParseURL(mongoURI)
//Below part is similar to above.
tlsConfig := &tls.Config{}
dialInfo.DialServer = func(addr *mgo.ServerAddr) (net.Conn, error) {
conn, err := tls.Dial("tcp", addr.String(), tlsConfig)
return conn, err
}
session, _ := mgo.DialWithInfo(dialInfo)