Python使用pymongo模块操作MongoDB的方法示例
时间:2018-07-20
这篇文章主要介绍了Python使用pymongo模块操作MongoDB的方法,结合实例形式分析了Python基于pymongo模块连接MongoDB数据库以及增删改查与日志记录相关操作技巧,需要的朋友可以参考下
本文实例讲述了Python使用pymongo模块操作MongoDB的方法。分享给大家供大家参考,具体如下:
通过pymongo实现python对Mongodb的操作。
具体看python代码
#!/usr/bin/python # coding=utf-8 #python实现对MongoDB的操作 #需要安装python2、pymongo、安装pymongo可能需要pip,logging打印日志 #改脚本主要功能就是每5秒改一次mongodb中存储的ip,5秒后再改回来 import pymongo import logging import datetime import os import time import traceback import sys,gc # 初始化logging logging.basicConfig(level=logging.NOTSET, format='%(asctime)s %(filename)s[line:%(lineno)d] [%(levelname)s] %(message)s', datefmt='%Y-%m-%d %H:%M:%S', filename='clear_screenshot_based_on_db.log', filemode='a') # set to print log to console at the same time console = logging.StreamHandler() console.setLevel(logging.NOTSET) formatter = logging.Formatter('%(asctime)s %(name)s [%(levelname)s] %(message)s') console.setFormatter(formatter) logging.getLogger('').addHandler(console) class MongoDB_Util(): #写一个类,用于实例化pymongo对象以及对mongo的增删改查 def __init__(self, user, password, host, port, database, max_pool_size=2): try: client = pymongo.MongoClient(host=host, port=port, maxPoolSize=max_pool_size) #实例化对象,需要mongo的相关参数 if client == None: logging.error( "MongoDB_Util.__init__ : Initialize mongodb client object error,host:%s port:%s" % ( host, port)) raise Exception("Initialize mongodb client object error") try: admin_db = client['admin'] #指定连接的库 admin_db.authenticate(user, password) #身份验证 self.persist_db = admin_db #赋值属性,通过该属性执行其他操作 except Exception as exp: logging.error( "MongoDB_Util.__init__ : Authtication failed,host:%s port:%s database:%s user:%s password:%s" % (host, port, database, user, password)) raise exp except Exception as exp: logging.error( "MongoDB_Util.__init__ : Exception has occured : %s" % str(sys.exc_info()[1])) raise exp def update(self): #update方法,对mongodb执行update操作 tom = None try: if self.persist_db == None: logging.error('MongoDB_Util.delete : Persist object has not been initialised') raise Exception('Persist object has not been initialised') collection = self.persist_db['fuzzing_agent.configuration'] #链接fuzzing_agent.configuration表 abc=collection.find({"default_value" : "10.10.1.179"}) #执行find命令 for i in abc: tom = i["default_value"] if tom == "10.10.1.179": #判断该值是否为179,如果是则通过update改为134 collection.update({"default_value" : "10.10.1.179"}, {'$set':{'default_value': '10.10.1.134'}}) collection.update({"default_value" : "10.10.1.179:/run/media/root/disk01/fuzzing"}, {'$set':{"default_value" :"10.10.1.134:/run/media/root/disk01/fuzzing"}}) logging.debug("179 > 134") time.sleep(5) else: collection.update({"default_value" : "10.10.1.134"}, {'$set':{'default_value': '10.10.1.179'}}) collection.update({"default_value" : "10.10.1.134:/run/media/root/disk01/fuzzing"}, {'$set':{"default_value" :"10.10.1.179:/run/media/root/disk01/fuzzing"}}) logging.debug("134 > 179") time.sleep(5) return except Exception as exp: logging.error('Mongodb_Util.delete : Exception has occured : ' + str(sys.exc_info()[1])) raise exp def change_ip(mongodb_host) : result = False try : mongo_util = MongoDB_Util('username', 'password', mongodb_host, 27017, 'admin',max_pool_size = 2) #用户名,密码,mongodb的Ip,端口,连接库,连接池 mongo_util.update() result = True except : logging.error('change_ip: Exception has occured : ' + traceback.format_exc()) finally: return result if __name__ == '__main__' : while True : try : if change_ip(mongodb_host = '127.0.0.1') : #mongodb的ip地址 logging.debug('update is done !!!') else : logging.error('not update done') except : logging.error('main : Exception has occured : ' + traceback.format_exc()) finally: logging.debug("one loop %s" %datetime.datetime.now())
更多关于Python相关内容感兴趣的读者可查看本站专题:《Python常见数据库操作技巧汇总》、《Python数学运算技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
- google gflag使用方法举例
- caffe源码学习之Proto数据格式【1】
- 降维之pca算法
- 聚类之dbscan算法
- ubuntu 使用sudo apt-get update 出现 被配置多次导致无法升级错误解决方法
- morestack与goroutine pool
- 关于python使用threadpool中的函数单个参数和多个参数用法举例
- python科学计算之numpy
- 关于python使用cv画矩形并填充颜色同时填充文字
- Go语言入门基础
- 【前端编程】加载第三方JS的各种姿势
- ubuntu16中遇到libgstreamer-0.10.so.0缺失解决方案
- 关于文件的压缩与解压
- Storm读取Kafka数据是如何实现的
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- PHP基础之排序
- 关于mysql limit offset的一点优化
- PHP基础之查找
- PHP木马免杀的一些总结
- PHP基础之面向对象篇
- PHP变量覆盖漏洞小结
- 算法复习 : 插入排序原理,记忆,时间复杂度 (7行java实现)
- PHP代码审计01之in_array()函数缺陷
- 分治思想 : 并归排序与其时间复杂度
- java Spring系列之 配置文件的操作 +Bean的生命周期+不同数据类型的注入简析+注入的原理详解+配置文件中不同标签体的使用方式
- 算法系列1 初识算法 算法复杂性模型 算法复杂度的计算
- 树莓派基础实验32:DS1302实时时钟模块实验
- Failed to parse date ["1534467411000"]:Invalid time zone indicator '0'
- 快速排序 : 调优:3亿数据40秒,2亿数据30秒,1亿数据15秒
- Spring系列之新注解配置+Spring集成junit+注解注入