【Python】pymongo使用

官方文档：http://api.mongodb.com/python/current/index.html

MongoReplicaSetClient：http://api.mongodb.com/python/current/api/pymongo/mongo_replica_set_client.html

mongo文档：https://docs.mongodb.com/manual/reference/command/

pymongo可以使用mongo command方法调用mongo方法

from pymongo import MongoClient
c = MongoClient("10.207.0.128:4000")
admin = c["admin"]
#获取实例状态
admin.command('serverStatus')
#副本集角色降级
admin.command("replSetStepDown",10)

from pymongo import MongoReplicaSetClient
#连接副本集
r= MongoReplicaSetClient(host = , port = , replicaSet = )
connection_admin=r.admin
connection_admin.authenticate('name','#')
#获取副本集主节点从节点
r.primary
r.secondaries

 

获得库对象和集合对象分别有两种方法：

db = client.test_database
# 或者
db = client['test-database']
得到一个数据集合：

collection = db.test_collection
# 或者
collection = db['test-collection']

 

 

连接认证 auth failed解决方法

注意MongoDB3.0版本以后采用的是'SCRAM-SHA-1'认证方式，pymongo需要更新2.8以上版本

http://api.mongodb.com/python/current/examples/authentication.html

 

mongo副本集rs.status()中

state：https://docs.mongodb.com/manual/reference/replica-states/

其他：https://docs.mongodb.com/manual/reference/command/replSetGetStatus/#dbcmd.replSetGetStatus

 

pymongo链接副本集读写分离和负载均衡的使用：

http://api.mongodb.com/python/current/examples/high_availability.html

 

from pymongo import MongoClient,ReadPreference
client = MongoClient(['host1:port','host2:port','host3:port'], replicaset='replset_name', readPreference='secondaryPreferred')
db_name = client.get_database('db_name',read_preference=ReadPreference.NEAREST)
db_name.authenticate('username','passwd',mechanism='SCRAM-SHA-1')

 

 

查询MongoDB有哪些库，库大小：

https://docs.mongodb.com/manual/reference/command/listDatabases/#dbcmd.listDatabases

admin.command("listDatabases",1)

command是库级别的，库、集合、副本集等操作要按照语法：

db_object.command({'command-name':'command-value'})
例如
db_test.command({ 'collStats' : 'collection-test})