1. 程式人生 > >Django專案之FastDFS檔案儲存系統

Django專案之FastDFS檔案儲存系統

0. 使用Docker安裝FastDFS

1. FastDFS的Python客戶端

安裝

安裝fdfs_client-py-master.zip到虛擬環境中

pip install fdfs_client-py-master.zip
pip install mutagen
pip install requests

配置

在專案/utils目錄下新建fastdfs目錄,新建client.conf配置檔案

# 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=FastDFS客戶端存放日誌檔案的目錄

# tracker_server can ocur more than once, and tracker_server format is
#  "host:port", host can be hostname or ip address
tracker_server=172.17.0.1: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

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

# FastDFS客戶端存放日誌檔案的目錄
base_path=
# 執行tracker服務的機器ip
tracker_server=172.17.0.1:22122 

2. 自定義Django檔案儲存系統

Django自帶檔案儲存系統,但是預設檔案儲存在本地,將檔案儲存到FastDFS伺服器上,所以需要自定義檔案儲存系統。

在專案/utils/fastdfs目錄中建立fdfs_storage.py檔案,實現可以使用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 @deconstructible class FastDFSStorage(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的檔名 """ 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 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.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 FastDFSStorage(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. 在Django配置中設定自定義檔案儲存類

在settings/dev.py檔案中新增設定

# django檔案儲存
DEFAULT_FILE_STORAGE = '專案名.utils.fastdfs.fdfs_storage.FastDFSStorage'

# FastDFS
FDFS_URL = 'http://域名:埠'  
FDFS_CLIENT_CONF = os.path.join(BASE_DIR, 'utils/fastdfs/client.conf')

4. 新增image域名

在/etc/hosts中新增訪問FastDFS storage伺服器的域名

127.0.0.1   xx域名