天天看點

自定義Django檔案存儲系統儲存檔案到FastDFS

1.前言:

Django自帶檔案存儲系統,但是預設檔案存儲在本地,在實際項目開發中,我們需要将檔案儲存到公司自己搭建的FastDFS伺服器上,是以需要自定義django的檔案存儲系統。

2.實作方法:

自定義檔案存儲系統的方法如下:

1)需要繼承自django.core.files.storage.Storage,如

from django.core.files.storage import Storage

class FastDFSStorage(Storage):
    ...
           

2)支援Django不帶任何參數來執行個體化存儲類,也就是說任何設定都應該從django.conf.settings中擷取

from django.conf import settings
from django.core.files.storage import Storage

class FasfDFSStorage(Storage):
    def __init__(self, base_url=None, client_conf=None):
        if base_url is None:
            base_url = settings.FDFS_URL
        self.base_url = base_url
        if client_conf is None:
            client_conf = settings.FDFS_CLIENT_CONF
        self.client_conf = client_conf
           

3)存儲類中必須實作_open()和_save()方法,以及任何後續使用中可能用到的其他方法。

  • _open(name, mode=‘rb’)

被Storage.open()調用,在打開檔案時被使用。

  • _save(name, content)

被Storage.save()調用,name是傳入的檔案名,content是Django接收到的檔案内容,該方法需要将content檔案内容儲存。

Django會将該方法的傳回值儲存到資料庫中對應的檔案字段,也就是說該方法應該傳回要儲存在資料庫中的檔案名稱資訊。

  • exists(name)

如果名為name的檔案在檔案系統中存在,則傳回True,否則傳回False。

  • url(name)

傳回檔案的完整通路URL

  • delete(name)

删除name的檔案

  • listdir(path)

列出指定路徑的内容

  • size(name)

傳回name檔案的總大小

注意,并不是這些方法全部都要實作,可以省略用不到的方法。

4)需要為存儲類添加django.utils.deconstruct.deconstructible裝飾器

3.使用示例

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


@deconstructible
class FasfDFSStorage(Storage):
    def __init__(self, base_url=None, client_conf=None):
        """
        初始化
        :param base_url: 用于構造圖檔完整路徑使用,圖檔伺服器的域名
        :param client_conf: FastDFS用戶端配置檔案的路徑
        """
        if base_url is None:
            base_url = settings.FDFS_URL
        self.base_url = base_url
        if client_conf is None:
            client_conf = settings.FDFS_CLIENT_CONF
        self.client_conf = client_conf

    def _open(self, name, mode='rb'):
        """
        用不到打開檔案,是以省略
        """
        pass

    def _save(self, name, content):
        """
        在FastDFS中儲存檔案
        :param name: 傳入的檔案名
        :param content: 檔案内容
        :return: 儲存到資料庫中的FastDFS的檔案名
        """
        # {
        # 'Local file name': '/home/python/1.jpg',
        # 'Storage IP': '192.168.189.133',
        # 'Remote file_id': 'group1/M00/00/00/wKi9hVz-Pm-Ab2WUAAOTipWhnKM344.jpg',
        #  'Group name': 'group1',
        # 'Status': 'Upload successed.',
        # 'Uploaded size': '228.00KB'
        # }
        
        client = Fdfs_client(self.client_conf)   # 執行個體化一個Fdfs_client對象
        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 url(self, name):
        """
        傳回檔案的完整URL路徑
        :param name: 資料庫中儲存的檔案名
        :return: 完整的URL
        """
        return self.base_url + name

    def exists(self, name):
        """
        判斷檔案是否存在,FastDFS可以自行解決檔案的重名問題
        是以此處傳回False,告訴Django上傳的都是新檔案
        :param name:  檔案名
        :return: False
        """
        return False
           
  1. 在Django配置中設定自定義檔案存儲類

    在settings/dev.py檔案中添加設定

4.django檔案存儲配置settings

DEFAULT_FILE_STORAGE = 'example.utils.fastdfs.fdfs_storage.FastDFSStorage'
# 具體的FasfDFSStorage這個類所在的子產品路徑

# FastDFS
FDFS_URL = 'http://image.example.site:8888/'  
FDFS_CLIENT_CONF = os.path.join(BASE_DIR, 'utils/fastdfs/client.conf')
# fastdfs配置檔案client_conf所在路徑
           

5.添加綁定FDFS_URL的域名

在/etc/hosts中添加通路FastDFS storage伺服器的網址開發時的域名

  • 首先:

    sudo vim /etc/hosts

  • 然後:空白處添加:

    127.0.0.1 image.example.site

  • :wq

    儲存退出

6.修改client_conf檔案

需要修改一下client.conf配置檔案

# the base path to store log files
base_path=/home/python/meiduo_15/meiduo_mall/logs

# tracker_server can ocur more than once, and tracker_server format is
#  "host:port", host can be hostname or ip address
tracker_server=192.168.189.135:22122
           

繼續閱讀