一: 單機鏈接

client = MongoClient('mongodb://localhost:27017/')

replication set 鏈接
from pymongo import MongoReplicaSetClient
conn = MongoReplicaSetClient("10.0.0.200:28017,10.0.0.200:28018,10.0.0.200:28019", replicaset='my_repl')

print (conn)
print (conn.primary)
print (conn.seeds)
print (conn.secondaries)
print (conn.read_preference)
print (conn.server_info())

二: 分片集群

conn = pymongo.Connection('192.168.1.1', 27017) 
db = conn['test'] #假定名為test的db已經(jīng)存在 
db_admin = conn['admin'] #command的執(zhí)行必須通過名為admin的db才能進(jìn)行 
col_data = db["data"] 
for i in range(1, 50): 

col_data.insert({'_id':i, 'value':(i*200)}) 
#插入測試數(shù)據(jù)，必須在分片之前保證shard key的存在，本例中為_id 
db_admin.command('enablesharding', 'test') 
#確認(rèn)目標(biāo)db的sharding功能開啟(這行代碼一個數(shù)據(jù)庫只執(zhí)行一次有效，如果已經(jīng)#設(shè)置，則會拋出異常)

db_admin.command('shardcollection', 'test.data', key = {'_id':1}) 
#指定目標(biāo)collection和對應(yīng)的shard key（這行一個表執(zhí)行一次，如果出現(xiàn)多表，表名不同的情況下，應(yīng)該每張表都執(zhí)行一次）

conn.close() 

如何查看已經(jīng)分片成功：
在linux中進(jìn)入mongo命令界面，
use test
db.test.data.stats()

會打印出分片信息。

并且shard key可以指定多個，同建立復(fù)合索引類似：
db_admin.command('shardcollection', 'test.data', key = {'_id':1, 'a':1, 'b':1})