深入探索 MongoDB GridFS:高效大文件存储与管理的全面指南
from pymongo import MongoClient
from gridfs import GridFS
# 连接到MongoDB
client = MongoClient('mongodb://localhost:27017/')
db = client.database
# 使用GridFS获取fs.files和fs.chunks集合
fs = GridFS(db)
# 下载文件
def download_file(filename):
with fs.open(filename) as f:
content = f.read()
return content
# 上传文件
def upload_file(filename, content):
with fs.new_file(filename=filename) as f:
f.write(content)
# 删除文件
def delete_file(filename):
fs.delete(filename)
# 示例:上传一个文件
upload_file('example.txt', b'Hello, GridFS!')
# 示例:下载刚上传的文件
downloaded_content = download_file('example.txt')
print(downloaded_content)
# 示例:删除刚上传的文件
delete_file('example.txt')
这段代码展示了如何使用PyMongo和GridFS来连接MongoDB,上传、下载和删除文件。这是一个简单的文件管理系统,适用于小型应用。
评论已关闭