微信登录

第三方库 - pymongo - 操作MongoDB

第三方库 - pymongo - 操作MongoDB

pymongo库的简介

Python 的 pymongo 库是 MongoDB 的官方 Python 驱动程序，它允许 Python 应用程序与 MongoDB 数据库进行交互。pymongo 提供了全功能的接口，用于操作 MongoDB 数据库，包括连接和配置数据库、创建和删除集合、插入和查询文档等。

此外，它还支持高级功能，如索引管理、聚合框架和网格FS。pymongo 库使用起来非常灵活，既可以用于简单的数据存储和检索，也可以用于复杂的数据分析和处理任务。它适用于需要快速开发和大数据操作的应用程序，如实时数据分析、内容管理系统和社交网络平台。通过 pymongo，开发者可以轻松地利用 MongoDB 的高性能和高可用性特性，构建可扩展的数据驱动应用程序。

安装Mongodb数据库连接库 pymongo 命令

  1. pip3 install pymongo

安装pymongo
不仅仅安装了pymongo，还安装了dnspython，dnspython是dns工具。它可用于查询、区域传输、动态更新、名称服务器测试和许多其他事情。

连接 MongoDB

  1. from pymongo import MongoClient
  3. # 连接方式一
  4. client = MongoClient(host='localhost',port=27017)
  5. # 连接方式二
  6. # client = MongoClient('mongodb://localhost:27017/')

选择MongoDB数据库

  1. MongoDB 可以创建很多 db，指定我们需要的 db 即可
  3. # 方式一
  4. db = client.Monitor
  5. # 方式二
  6. # db = client['Monitor']

选择集合

  1. db 内包含很多个集合，有点类似 mysql 这类关系型数据库中的表
  3. # 方式一
  4. collection = db.test
  5. # 方式二
  6. # collection = db['test']

各种mongodb语句

mongodb原生语句命令 - 查 - db.xx.find() - 与mysql对比)

  1. rep = collection.find({}, {'field1': 1}).sort([('_id', -1)]).limit(1)
  2. rep = collection.insert_one(dic)
  3. rep = collection.insert_many(lists)
  4. rep = collection.find(dic)
  5. rep = collection.find({'yourCollectionName':{'$regex':'^yourWords'}})  # 正则表达式
  6. rep = collection.find_one(dic)
  7. rep = collection.update_one(condition,{'$set':dic})
  8. rep = collection.update_many(condition,{'$set':dic})
  9. rep = collection.delete_one(dic)
  10. rep = collection.delete_many(dic)
  11. rep = collection.find({},{'field1': 1}).distinct("field2")
  12. 只返回列表：['a','b']
  13. 这里只有方法名，具体看MongoDB
  14. rep = collection.find().sort('time_field', -1).limit(10)  # 时间最前10条
  16. # 查询字段col_name的最大值
  17. max_value = collection.find().sort('col_name', -1).limit(1)[0]['col_name']

写成类

  1. # 文章操作
  2. from app import mongo_client
  4. class collection_doc():
  5.     def __init__(self):
  6.         self.db = "test"  # 数据库名
  7.         self.collection = "test"  # 表名
  8.     # 查
  9.     def find(self, id):
  10.         try:
  11.             data = mongo_client[self.db][self.collection].find({"_id":id})
  12.             return data
  13.         except:
  14.             raise
  15.     # 改
  16.     def update(self, id, name, today):
  17.         try:
  18.             mongo_client[self.db][self.collection].update_one({"_id":id}, {"$set":{条件}})
  19.         except:
  20.             raise
  21.     # 增
  22.     def insertMany(self, data):
  23.         try:
  24.             mongo_client[self.db][self.collection].insert_many(data)
  25.         except:
  26.             raise

写成类的好处很多：
1、可以随时复制多一个类，换一个数据库名和表名，还有一些写法留着，修改一下参数就可以使用了。
2、以后有可能进行一些修改，快速找到库曾经在什么地方使用过，以便后续更改。
3、业务逻辑更清晰，因为业务逻辑很有可能涉及各种数据库、缓存、执行顺序、条件判断的影响。

连接mongdb分片

  1. from pymongo import MongoClient
  3. # MongoDB分片配置服务器地址列表
  4. config_servers = [
  5.     "configsvr1.example.com:27019",
  6.     "configsvr2.example.com:27019",
  7.     "configsvr3.example.com:27019"
  8. ]
  10. # MongoDB分片键
  11. shard_key = "myShardKey"
  13. # 创建MongoClient实例连接到分片集群
  14. client = MongoClient(config_servers, replicaSet="shard0/shard1/shard2")
  1. # 获取数据库和集合，进行数据操作
  2. db = client.mydb
  3. collection = db.mycollection
  5. # 示例：插入文档
  6. collection.insert_one({shard_key: "value1", "data": "example data"})

确保替换
configsvr1.example.com:27019,
configsvr2.example.com:27019,
configsvr3.example.com:27019
为你的配置服务器地址，
以及shard0/shard1/shard2为你的副本集名称replicaSet。
同时，替换mydb和mycollection为你的数据库和集合名称。

pymongo疑难杂症

https://www.osgeo.cn/mongo-python-driver/changelog.html
这是变更目录，有一些奇奇怪怪的问题在这里得到解决，例如更新版本才可以解决等等

第三方库 - pymongo - 操作MongoDB