您好,登录后才能下订单哦!
#
-
*
-
coding
:
utf
-
8
-
*
-
import datetime
import pymongo
import time
client
=
pymongo
.
MongoClient
(
"127.0.0.1"
,
27017
)
db
=
client
.
get_database
(
"collection"
)
db
.
authenticate
(
'collection'
,
'78hRdJEnJcHRb4qA'
)
#print ( db . collection_names ( ) )
redefine_collection
=
db
.
get_collection
(
'redefine-collection'
)
alluser=[]
demos
=
redefine_collection
.
find
(
{
'event_id'
:
'0109001'
,
'event_info.url'
:
{
'$exists'
:
'true'
}
,
"ctime"
:
{
"$gte"
:
1525881600000}}
,
no_cursor_timeout
=
True
)
for
item
in
demos
:
if
len
(
item
[
'event_info'
]
[
'url'
]
.
replace
(
r
'/'
,
''
)
.
split
(
'.'
)
[
-
1
]
)
<
=
5
:
alluser
.
append
(
item
[
'event_info'
]
[
'url'
]
.
replace
(
r
'/'
,
''
)
.
split
(
'.'
)
[
-
1
]
)
demos
.
close
(
)
print len
(
alluser
)
from pymongo import MongoClient
conn
=
MongoClient
(
[
'192.168.3.11:27017'
,
'192.168.3.12:27017'
,
'192.168.3.13:27017'
],replicaset='shard1'
)
from pymongo import ReadPreference
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') ###获取对应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
参考:http : / / blog . 51cto . com/hnr520/1874506
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。