使用Python实现操作mongodb详解
一、示例
from pymongo import MongoClient from urllib.parse import quote class test_mongo: def __init__(self, host,port,user,pwd,db): self.host = host self.port = port self.user = user self.pwd = pwd self.db = db def build_conn_mongo(self): """ 功能:实现创建客户端 :return: client """ escaped_username = quote(self.user, safe='') escaped_password = quote(self.pwd, safe='') # 创建客户端对象,连接MongoDB服务器 client = MongoClient('mongodb://{0}:{1}@{2}:{3}/{4}'.format(escaped_username, escaped_password, self.host, self.port, self.db)) return client def check_mongo(self,query=None): """ 功能:查询信息 :param query:输入查询条件 eg:{"paId": "38ffefbe29ddcf3c9f574aa"} :return:返回信息,以及获取查询的条数 """ client = self.build_conn_mongo() db = client.iot_ota collection = db.集合名称 results = collection.find(query) count= collection.count_documents(query) client.close() return results,count def update_mongo_by_query(self,query, set_value): """ 功能:按照条件修改一个记录 :param query:输入查询条件 eg:query1 = {"paId": "38ffefbe291a375c4aa"} :param set_value:eg:{"$set":{"description":"yz测试"}} :return:返回基本信息 """ client = self.build_conn_mongo() db = client.iot_ota collection = db.集合名称 results = collection.update_one(query, set_value) client.close() return results def delete_package_by_query(self,query): """ 功能:按照条件删除一个记录 :param query:输入查询条件 eg:{"otId":202501221} :return: """ client = self.build_conn_mongo() db = client.iot_ota collection = db.集合名称 results = collection.delete_one(query) client.close() return results
二、常用指令
序号 | 指令 | 描述 |
---|---|---|
1 | db = client.数据库名 | 获取数据库 |
2 | db.collection.find() | 筛选所有记录 |
3 | db.collection.find({“key”:value}) | 按照条件进行查询记录 |
4 | db.collection.count_documents(query) | 按照条件查询符合记录的条数 |
5 | db.collection.update_one(query, set_value)) | 更新一条记录 |
6 | db.collection.delete_one(query) | 删除一条记录 |
三、遇到的问题
1、转义账户和密码,解决不符合RFC规范的问题
由于使用账号和密码中包含特殊字符出发点报如下错误:
Username and password must be escaped according to RFC 3986, use urllib.parse.quote_plus
解决办法:
用Python的urllib.parse模块中的quote函数来对用户名和密码进行转义
2、未指定权限内数据库,导致报权限错误
报错:pymongo.errors.OperationFailure: Authentication failed具体如下图
解决办法:–由于使用的账户的权限只有更db_name的权限,此处如不指明具体的数据库,则无法访问client = MongoClient(‘mongodb://{0}:{1}@X.x.x.x:27017/db_name’.format(escaped_username,escaped_password))
3、较新版本的PyMongo中,update和remove方法已经被弃用
解决方法:
使用update_one()和update_many()方法来进行单条记录或多条记录的更新操作
使用delete_one和delete_many方法来替代remove
到此这篇关于使用Python实现操作mongodb详解的文章就介绍到这了,更多相关Python操作mongodb内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
pandas数据分组groupby()和统计函数agg()的使用
这篇文章主要介绍了pandas数据分组groupby()和统计函数agg()的使用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2021-03-03
最新评论