1
2
3
4
5
6
7
8
9
10

{
  "_id": <ObjectId>,    // 文档 ID，唯一标识
  "chunkSize": <num>,   // chunk 大小 256kb
  "uploadDate": <timetamp>, //文件上传时间
  "length": <num>,      // 文件长度
  "md5": <string>,      // 文件 md5 值 (7.0 已弃用)
  "filename": <string>, // 文件名
  "contentType": <string>,// 文件的?MIME类型 (7.0 已弃用)
  "metadata": <dataObject>// 文件自定义信息
}

1
2
3
4
5
6

{
  "_id": <ObjectId>,    // 文档 ID，唯一标识
  "files_id": <ObjectId>,    // 对应 fs.files 文档的 ID
  "n": <num>,           // 序号，标识文件的第几个 chunk
  "data": <binary>      // 文件二级制数据
}

1
2
3

#mongofiles -h -u  -p  --db files put /conn.log
connected to: 127.0.0.1
added file: { _id: ObjectId('530cf1009710ca8fd47d7d5d'),filename: "./conn.log", chunkSize: 262144, uploadDate: newDate(1393357057021), md5: "6515e95f8bb161f6435b130a0e587ccd", length:1644981 }

1
2
3

#mongofiles -h -u  -p  --db files get /conn.log
connected to: 127.0.0.1
done write to: ./conn.log

1
2
3

# mongofiles -h -u  -p  list
connected to: 127.0.0.1
/conn.log 1644981

1
2

[root@ip-10-198-25-43 tmp]# mongofiles -h  -u -p  --db files delete /conn.log
connected to: 127.0.0.1

1

pip install pymongo

1
2
3
4
5
6
7
8
9
10

from pymongo import MongoClient
from gridfs import GridFS
if __name__ == '__main__':
    #建立MongoDB数据库连接
    conn = MongoClient(host='127.0.0.1',port=27017)
    mydb = conn['test']
    fs = GridFS(mydb)

1
2
3
4
5
6
7
8
9
10

image_path = 'test.jpg'
with open(image_path, 'rb') as file:
    custom_id = 'my_img_id'
    # 检查自定义ID是否已经存在
    if not fs.exists(_id=custom_id):
        fs.put(file.read(), _id=custom_id, filename=image_file_name, content_type='image/jpeg')
        print(f"Image '{image_file_name}' saved with custom id: {custom_id}")
    else:
        print(f"Image '{image_file_name}' with custom id: {custom_id} already exists.")

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

from PIL import Image
from io import BytesIO
from pymongo import MongoClient
from gridfs import GridFS
# MongoDB连接设置
mongo_host = 'your_mongodb_host'
mongo_port = 27017  # 根据实际情况修改端口
mongo_db_name = 'image_database'
mongo_user = 'your_username'
mongo_password = 'your_password'
# 连接到MongoDB
client = MongoClient(mongo_host, mongo_port, username=mongo_user, password=mongo_password)
db = client[mongo_db_name]
fs = GridFS(db)
# 自定义ID，即你之前保存图像时使用的ID
custom_id = 'your_custom_image_id_here'
# 从GridFS读取图像
if fs.exists(_id=custom_id):
    file = fs.get(custom_id)
    image = Image.open(BytesIO(file.read()))
    image.show()
    print(f"Image with custom id: {custom_id} displayed.")
else:
    print(f"No image found with custom id: {custom_id}")
# 关闭数据库连接
client.close()

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

from pymongo import MongoClient
from gridfs import GridFS
# MongoDB连接设置
mongo_host = 'your_mongodb_host'
mongo_port = 27017  # 根据实际情况修改端口
mongo_db_name = 'image_database'
mongo_user = 'your_username'
mongo_password = 'your_password'
# 连接到MongoDB
client = MongoClient(mongo_host, mongo_port, username=mongo_user, password=mongo_password)
db = client[mongo_db_name]
fs = GridFS(db)
# 列出GridFS中所有图像的ID
try:
    files = fs.find()
    for file in files:
        print(f"File ID: {file._id}")
except Exception as e:
    print(f"An error occurred: {e}")
# 关闭数据库连接
client.close()

1
2
3
4
5

# 列出GridFS中所有JPEG图像的ID
files = fs.find({'contentType': 'image/jpeg'})
for file in files:
    print(f"JPEG Image ID: {file._id}")

1
2
3
4
5
6
7
8

from datetime import datetime
# 查询上传日期在特定日期之后的文件
upload_date = datetime(2023, 1, 1)
files = fs.find({'uploadDate': {'$gte': upload_date}})
for file in files:
    print(f"File ID: {file._id}, Filename: {file.filename}, Upload Date: {file.uploadDate}")

1
2
3
4
5
6

# 查询文件大小大于特定值的文件
min_file_size = 1024 * 1024 * 5  # 5MB
files = fs.find({'length': {'$gte': min_file_size}})
for file in files:
    print(f"File ID: {file._id}, Filename: {file.filename}, Size: {file.length} bytes")

1

fs.delete(file_id)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

from pymongo import MongoClient
from gridfs import GridFS
# MongoDB连接设置
mongo_host = 'your_mongodb_host'
mongo_port = 27017  # 根据实际情况修改端口
mongo_db_name = 'image_database'
mongo_user = 'your_username'
mongo_password = 'your_password'
# 连接到MongoDB
client = MongoClient(mongo_host, mongo_port, username=mongo_user, password=mongo_password)
db = client[mongo_db_name]
fs = GridFS(db)
# 要删除的文件的ID
file_id_to_delete = 'your_file_id_here'
# 删除文件
if fs.exists(file_id_to_delete):
    fs.delete(file_id_to_delete)
    print(f"File with ID {file_id_to_delete} has been deleted.")
else:
    print(f"No file found with ID {file_id_to_delete}.")
# 关闭数据库连接
client.close()

1
2
3
4
5
6
7
8
9
10
11
12
13

# 删除条件，例如删除所有内容类型为'image/jpeg'的文件
delete_condition = {'contentType': 'image/jpeg'}
# 查询符合条件的文件
files_to_delete = fs.find(delete_condition)
# 删除每个找到的文件
for file in files_to_delete:
    fs.delete(file._id)
    print(f"File with ID {file._id} has been deleted.")
# 关闭数据库连接
client.close()