django中使用FastDFS分布式文件系统接口代码实现文件上传、下载、更新、删除

fastdfs  tracker 192.168.1.216   192.168.1.217  storage 192.168.1.216  192.168.1.217

pip install fdfs_client-py-master.zip

pip install mutagen

pip install requests

# connect timeout in seconds
# default value is 30s
connect_timeout=30

# network timeout in seconds
# default value is 30s
network_timeout=60

# the base path to store log files
#客户端存放日志目录，可自行设置
base_path=/Users/delron/Desktop

# tracker_server can ocur more than once, and tracker_server format is
#  "host:port", host can be hostname or ip address
#改成自己的ip即可，配置一个即可tracker会自行帮助我们进行任务调度
tracker_server=192.168.1.217:22122

#standard log level as syslog, case insensitive, value list:
### emerg for emergency
### alert
### crit for critical
### error
### warn for warning
### notice
### info
### debug
log_level=info

# if use connection pool
# default value is false
# since V4.05
use_connection_pool = false

# connections whose the idle time exceeds this time will be closed
# unit: second
# default value is 3600
# since V4.05
connection_pool_max_idle_time = 3600

# if load FastDFS parameters from tracker server
# since V4.05
# default value is false
load_fdfs_parameters_from_tracker=false

# if use storage ID instead of IP address
# same as tracker.conf
# valid only when load_fdfs_parameters_from_tracker is false
# default value is false
# since V4.05
use_storage_id = false

# specify storage ids filename, can use relative or absolute path
# same as tracker.conf
# valid only when load_fdfs_parameters_from_tracker is false
# since V4.05
storage_ids_filename = storage_ids.conf


#HTTP settings
http.tracker_server_port=80

#use "#include" directive to include HTTP other settiongs
##include http.conf

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2019/4/26 10:09
# @Author  : suihongliang
# @Site    : 
# @File    : fastdfs_service.py
# @Software: PyCharm
"""
使用fastdfs分布式文件存储系统实现文件的上传、下载、删除
"""
from django.conf import settings
from django.core.files.storage import Storage
from django.utils.deconstruct import deconstructible
from fdfs_client.client import Fdfs_client
from utils.logger_utils import get_logging

logger = get_logging(__name__)


@deconstructible
class FastDFSStorage(Storage):
    def __init__(self, client_conf=None):
        """
        初始化
        :param client_conf: FastDFS客户端配置文件的路径
        """
        if client_conf is None:
            client_conf = settings.FDFS_CLIENT_CONF
        self.client_conf = client_conf

    # def upload(self, content):
    #     """
    #     在FastDFS中保存文件
    #     :param content: 通过
    #     :return: 保存到数据库中的FastDFS的文件名
    #     """
    #     client = Fdfs_client(self.client_conf)
    #     ret = client.upload_by_buffer(content.read())
    #     if ret.get("Status") != "Upload successed.":
    #         raise Exception("upload file failed")
    #     file_name = ret.get("Remote file_id")
    #     return file_name

    def upload(self, local_path):
        """
        将文件上传到fastdfs分布式文件系统中
        :param local_path: 上传文件的本地路径
        :return:
        """
        client = Fdfs_client(self.client_conf)
        ret = client.upload_by_file(local_path)
        logger.info(ret)
        print(ret)
        if ret.get("Status") != "Upload successed.":
            raise Exception("upload file failed")
        remote_file_id = ret.get("Remote file_id")
        logger.info("存储在fastdfs上的文件路径：", remote_file_id)

        return True, remote_file_id

    def update(self, local_path, remote_file_id):
        """
        对修改后的文件进行更新
        :param local_path:
        :param remote_file_id:
        @return: dictionary {
            ‘Status‘     : ‘Modify successed.‘,
            ‘Storage IP‘ : storage_ip
        }
        """
        client = Fdfs_client(self.client_conf)
        try:
            local_path=bytes(local_path.encode("utf-8"))
            remote_file_id=bytes(remote_file_id.encode("utf-8"))
            ret_update = client.modify_by_file(local_path, remote_file_id)
            logger.info("文件更新成功",ret_update)
            return True, ret_update
        except Exception as e:
            logger.warning(u‘文件更新失败，错误信息：%s‘ % repr(e))
            return None, "文件更新失败"

    def download(self, local_path, remote_file_id):
        """
        从fastdfs分布式文件系统进行下载文件
        :param local_path: 本地保存文件路径
        :param remote_file_id: 上传到fastdfs文件系统中自动生成的文件路径即文件id
        @return dict {
            ‘Remote file_id‘  : remote_file_id,
            ‘Content‘         : local_filename,
            ‘Download size‘   : downloaded_size,
            ‘Storage IP‘      : storage_ip
        }
        """
        client = Fdfs_client(self.client_conf)
        try:
            ret_download = client.download_to_file(local_path, remote_file_id)
            return True, ret_download

        except Exception as e:
            logger.warning(u‘文件下载失败，错误信息：%s‘ % repr(e))
            return None, "文件下载失败"

    def delete(self, remote_file_id):
        """
        从fastdfs分布式文件系统中将文件删除
        :param remote_file_id: 上传到fastdfs文件系统中自动生成的文件路径即文件id
        @return tuple (‘Delete file successed.‘, remote_file_id, storage_ip)
        """
        client = Fdfs_client(self.client_conf)
        try:
            ret_delete = client.delete_file(remote_file_id)
            return ret_delete

        except Exception as e:
            logger.warning(u‘文件删除失败，错误信息：%s‘ % repr(e))
            return None

# fastdf配置文件设置
#
DEFAULT_FILE_STORAGE = ‘distributedstorage.utils.fastdfs.fdfs_storage.FastDFSStorage‘

# FastDFS
# fastdfs  tracker 192.168.1.212   192.168.1.213  storage 192.168.1.212  192.168.1.213
# FDFS_CLIENT_CONF = os.path.join(BASE_DIR, ‘utils/fastdfs/client.conf‘)
FDFS_CLIENT_CONF = os.path.join(BASE_DIR, ‘client.conf‘)