文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

【Python】pymongo链接mongo

2024-04-02 19:55

关注

pymongo模块链接mongo

1.链接单实例mongo

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

  2. import datetime

  3. import pymongo

  4. import time


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

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

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

  8. #print ( db . collection_names ( ) )

  9. 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.连接复制集

  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')             ###获取对应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



阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯