1. 程式人生 > >FastDFS客戶端與自定義檔案儲存系統

FastDFS客戶端與自定義檔案儲存系統

1. FastDFS的Python客戶端

安裝

安裝提供給大家的fdfs_client-py-master.zip到虛擬環境中

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

使用

使用FastDFS客戶端,需要有配置檔案。我們在meiduo_mall/utils目錄下新建fastdfs目錄,將提供給大家的client.conf配置檔案放到這個目錄中。

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

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

上傳檔案需要先建立fdfs_client.client.Fdfs_client的物件,並指明配置檔案,如

from fdfs_client.client import Fdfs_client
client = Fdfs_client('meiduo_mall/utils/fastdfs/client.conf')

通過建立的客戶端物件執行上傳檔案的方法

client.upload_by_filename(檔名)
或
client.upload_by_buffer(檔案bytes資料)

如:

>>> ret = client.upload_by_filename('/Users/delron/Desktop/1.png')
getting connection
<fdfs_client.connection.Connection object at 0x1098d4cc0>
<fdfs_client.fdfs_protol.Tracker_header object at 0x1098d4908>
>>> ret
{'Group name': 'group1', 'Remote file_id': 'group1/M00/00/02/CtM3BVr-k6SACjAIAAJctR1ennA809.png', 'Status': 'Upload successed.', 'Local file name': '/Users/delron/Desktop/1.png', 'Uploaded size': '151.00KB', 'Storage IP': '10.211.55.5'}
>>>
  • Remote file_id 即為FastDFS儲存的檔案的路徑

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

在學習Django框架的時候,我們已經講過,Django自帶檔案儲存系統,但是預設檔案儲存在本地,在本專案中,我們需要將檔案儲存到FastDFS伺服器上,所以需要自定義檔案儲存系統。

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

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裝飾器

我們在meiduo_mall/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 _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

3. 在Django配置中設定自定義檔案儲存類

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

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

# FastDFS
FDFS_URL = 'http://image.meiduo.site:8888/'  
FDFS_CLIENT_CONF = os.path.join(BASE_DIR, 'utils/fastdfs/client.conf')

4. 新增image域名

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

127.0.0.1   image.meiduo.site