面试题答案
一键面试- 安装库:
- 确保
pymongo
和DBUtils
已安装。如果没有安装,可以使用pip install pymongo DBUtils
进行安装。
- 确保
- 实现步骤:
- 导入必要的模块。
- 创建一个函数来获取MongoDB连接。
- 使用
DBUtils
的PooledDB
来创建连接池。
- 关键代码示例:
from dbutils.pooled_db import PooledDB
from pymongo import MongoClient
def get_mongo_connection():
# 创建MongoDB连接池
pool = PooledDB(
creator=MongoClient,
host='localhost',
port=27017,
maxconnections=10,
blocking=True
)
# 从连接池获取一个连接
connection = pool.connection()
return connection
# 使用连接
mongo_conn = get_mongo_connection()
db = mongo_conn['your_database']
collection = db['your_collection']
data = collection.find_one()
print(data)
# 归还连接到连接池
mongo_conn.close()
上述代码中:
PooledDB
的creator
参数指定使用MongoClient
来创建连接。host
和port
指定MongoDB服务器的地址和端口。maxconnections
设置最大连接数。blocking
设置为True
,表示当连接池满时,请求连接的操作会阻塞直到有连接可用。