【Python】pymongo链接mongo

pymongo模块链接mongo

1.链接单实例mongo

1. # - * - coding : utf - 8 - * -
   

2. import datetime
   

3. import pymongo
   

4. import time
   

5. 
   

6. client = pymongo . MongoClient ( "127.0.0.1" , 27017 )
   

7. db = client . get_database ( "collection" )
   

8. db . authenticate ( 'collection' , '78hRdJEnJcHRb4qA' )
   

9. #print ( db . collection_names ( ) )

10. redefine_collection = db . get_collection ( 'redefine-collection' )
    

alluser=[]

1. demos = redefine_collection . find ( { 'event_id' : '0109001' , 'event_info.url' : { '$exists' : 'true' } , "ctime" : { "$gte" : 1525881600000}} , no_cursor_timeout = True )
   

2. for item in demos :
   

3. if len ( item [ 'event_info' ] [ 'url' ] . replace ( r '/' , '' ) . split ( '.' ) [ - 1 ] ) < = 5 :
   

4. alluser . append ( item [ 'event_info' ] [ 'url' ] . replace ( r '/' , '' ) . split ( '.' ) [ - 1 ] )
   

5. demos . close ( )
   

6. print len ( alluser )
   

7. 
   

2.连接复制集

1. from pymongo import MongoClient
   

2. conn = MongoClient ( [ '192.168.3.11:27017' , '192.168.3.12:27017' , '192.168.3.13:27017' ],replicaset='shard1' )
   

3. from pymongo import ReadPreference
   

4. db = conn . get_database ( 'hnrtest' , read_preference = ReadPreference . SECONDARY_PREFERRED )
   

3.mongo常见操作

# #####read client# client = pymongo.MongoReplicaSetClient(['172.31.46.25:27017,172.31.43.36:27017,172.31.40.242:27017'],replicaset='shard1')# db = client.get_database("collection")# db.authenticate('collection', '78hRdJEnJcHRb4qA')## print db.client.read_preference# print db.client.primary# print db.client.secondaries# print db.client.arbiters# print db.command('ismaster')#####read clientclient = pymongo.MongoClient(['172.31.32.223:20000'])db = client.get_database("admin")db.authenticate('admin', 'ggxP6tPI971K3W0r')# print db.client.read_preference# print db.client.primary# print db.client.secondaries# print db.client.arbiters# print db.client.is_primary# print db.command('ismaster')# print db.command('currentOp')# print db.command('replSetGetStatus')# print db.list_collection_names()statement=client.collection.get_collection('statement')             ###获取对应db下的对应集合print statement.count()# client.collection.add_user('newTestUser', 'Test123', roles=[{'role':'readWrite','db':'collection'}])  ####添加用户# client.collection.remove_user('newTestUser')  ####删除用户db2 = client.get_database("collection")db2.add_user('newTestUser', 'Test123', roles=[{'role':'readWrite','db':'collection'}])  ###添加用户print db.current_op()# options = {'lock': True}# db.client.fsync(**options)# print db.client.is_locked# ##### print db.command('fsyncUnlock')# print db.client.is_locked

1. 参考：http : / / blog . 51cto . com/hnr520/1874506