fastdfs上传文件，删除文件，预览文件

FastDFS 是一个开源的轻量级分布式文件系统，它主要解决了海量文件存储问题，具有高性能、高可靠性、易扩展性等特点。下面介绍一下 FastDFS 的文件上传、删除和预览操作。

1. 文件上传

FastDFS 的文件上传分为两步，第一步是上传文件到 FastDFS 服务器，第二步是保存文件元数据到数据库中。

上传文件到 FastDFS 服务器：

import os
from fdfs_client.client import Fdfs_client

# 定义 FastDFS 配置文件路径
FDFS_CLIENT_CONF = '/etc/fdfs/client.conf'

# 创建 Fdfs_client 对象
client = Fdfs_client(FDFS_CLIENT_CONF)

# 上传本地文件
ret = client.upload_by_filename('/path/to/local/file')
if ret.get('Status') == 'Upload successed.':
    # 获取文件 ID
    file_id = ret.get('Remote file_id')
else:
    # 上传失败
    file_id = None

保存文件元数据到数据库中：

from sqlalchemy.orm import sessionmaker
from models import File
from database import engine

# 创建数据库连接
Session = sessionmaker(bind=engine)
session = Session()

# 创建文件对象并保存到数据库中
file = File(file_id=file_id, filename='example.txt', size=os.path.getsize('/path/to/local/file'))
session.add(file)
session.commit()

2. 文件删除

FastDFS 的文件删除也分为两步，第一步是删除 FastDFS 服务器上的文件，第二步是从数据库中删除文件元数据。

删除 FastDFS 服务器上的文件：

from fdfs_client.client import Fdfs_client

# 创建 Fdfs_client 对象
client = Fdfs_client(FDFS_CLIENT_CONF)

# 删除文件
ret = client.delete_file(file_id)
if ret == 0:
    # 删除成功
    pass
else:
    # 删除失败
    pass

从数据库中删除文件元数据：

from sqlalchemy.orm import sessionmaker
from models import File
from database import engine

# 创建数据库连接
Session = sessionmaker(bind=engine)
session = Session()

# 获取文件对象并从数据库中删除
file = session.query(File).filter_by(file_id=file_id).first()
if file:
    session.delete(file)
    session.commit()

3. 文件预览

FastDFS 的文件预览需要在客户端下载文件并提供预览功能，具体实现方式根据业务需求而定。例如，可以使用 Flask 框架提供 Web 服务，通过浏览器访问预览页面。

from flask import Flask, send_file
from fdfs_client.client import Fdfs_client

# 创建 Flask 应用
app = Flask(__name__)

# 定义 FastDFS 配置文件路径
FDFS_CLIENT_CONF = '/etc/fdfs/client.conf'

@app.route('/preview/<file_id>')
def preview(file_id):
    # 创建 Fdfs_client 对象
    client = Fdfs_client(FDFS_CLIENT_CONF)

    # 下载文件到本地
    ret = client.download_to_buffer(file_id)
    if ret.get('Content') is not None:
        # 返回文件内容
        return send_file(ret.get('Content'), attachment_filename='example.txt')
    else:
        # 下载失败
        return 'Download failed.'

if __name__ == '__main__':
    app.run()

在浏览器中访问 http://localhost:5000/preview/{file_id} 即可预览文件。