pymongo模塊鏈接mongo

1.鏈接單實例mongo

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

   

   從事綿陽電信機房機柜租用，服務(wù)器租用，云主機，網(wǎng)站空間，域名與空間，CDN，網(wǎng)絡(luò)代維等服務(wù)。

2. import datetime

3. import pymongo

4. import time

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 )

2.連接復(fù)制集

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 client
client = 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')             ###獲取對應(yīng)db下的對應(yīng)集合
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

分享名稱：【Python】pymongo鏈接mongo-創(chuàng)新互聯(lián)
網(wǎng)頁路徑：http://chinadenli.net/article44/gsphe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供虛擬主機、微信公眾號、域名注冊、建站公司、網(wǎng)站收錄、網(wǎng)站制作

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)