sql >> Databáze >  >> NoSQL >> MongoDB

Připojení k MongoDB Atlas pomocí Golang mgo:Trvalý nedostupný server pro sadu replik

Použití úryvku mgo kódu ovladače MongoDB Go níže pro připojení k MongoDB Atlas funguje s použitím vašich vzorových dat:

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)

Všimněte si, že můžete také zadat pouze jeden z členů sady replik jako zdroj. Například:

Addrs: []string{"prefix2.mongodb.net:27017"}

Viz také:

  • tls.Dial()
  • DialInfo
  • DialWithInfo

Aktualizovat :

Můžete také použít metodu ParseURL() k analýze řetězce URI MongoDB Atlas. V současnosti však tato metoda nepodporuje SSL (mgo.V2 PR:304)

Řešením je odstranit ssl=true řádek před analýzou.

//URI without ssl=true
var mongoURI = "mongodb://username:[email protected],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)



  1. Je rámec Mongodb Aggregation rychlejší než map/reduce?

  2. Mongodb:proč show dbs nezobrazuje mé databáze?

  3. Počkejte na zpětné volání funkce async v události last stream.on('data').

  4. Synchronizujte MongoDB přes ssh