python
from pymongo import MongoClient
from pymongo.errors import AutoReconnect
def connect_replica_set():
try:
client = MongoClient("mongodb://localhost:27017,localhost:27018,localhost:27019/?replicaSet=myReplicaSet")
db = client.myDatabase
print("Successfully connected to the replica set!")
return db
except AutoReconnect:
print("Failed to connect to the replica set!")
db = connect_replica_set()
script
mongod --configsvr --dbpath /data/configdb --port 27019
mongod --shardsvr --replSet shard1 --dbpath /data/db --port 27017
mongo --port 27019
sh.addShard("shard1/localhost:27017")
use myDatabase
sh.enableSharding("myDatabase")
sh.shardCollection("myDatabase.myCollection", { "_id": "hashed" })
