1. FastDFS的Python客戶端
python版本的FastDFS客戶端使用說明參考https://github.com/jefforeilly/fdfs_client-py
安裝
安裝提供給大家的fdfs_client-py-master.zip到虛擬環境中
pip install fdfs_client-py-master.zip
pip install mutagen
pip isntall 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中獲取
1 from django.conf import settings 2 from django.core.files.storage import Storage 3 4 class FasfDFSStorage(Storage): 5 def __init__(self, base_url=None, client_conf=None): 6 if base_url is None: 7 base_url = settings.FDFS_URL 8 self.base_url = base_url 9 if client_conf is None: 10 client_conf = settings.FDFS_CLIENT_CONF 11 self.client_conf = client_conf
3)存儲類中必須實現_open()
和_save()
方法,以及任何后續使用中可能用到的其他方法。
-
_open(name, mode='rb')
被Storage.open()調用,在打開文件時被使用。
-
_save(name, content)
被Storage.save()調用,name是傳入的文件名,content是Django接收到的文件內容,該方法需要將content文件內容保存。
-
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存儲文件的存儲類如下
1 from django.conf import settings 2 from django.core.files.storage import Storage 3 from django.utils.deconstruct import deconstructible 4 from fdfs_client.client import Fdfs_client 5 6 7 @deconstructible 8 class FasfDFSStorage(Storage): 9 def __init__(self, base_url=None, client_conf=None): 10 """ 11 初始化 12 :param base_url: 用於構造圖片完整路徑使用,圖片服務器的域名 13 :param client_conf: FastDFS客戶端配置文件的路徑 14 """ 15 if base_url is None: 16 base_url = settings.FDFS_URL 17 self.base_url = base_url 18 if client_conf is None: 19 client_conf = settings.FDFS_CLIENT_CONF 20 self.client_conf = client_conf 21 22 def _open(self, name, mode='rb'): 23 """ 24 用不到打開文件,所以省略 25 """ 26 pass 27 28 def _save(self, name, content): 29 """ 30 在FastDFS中保存文件 31 :param name: 傳入的文件名 32 :param content: 文件內容 33 :return: 保存到數據庫中的FastDFS的文件名 34 """ 35 client = Fdfs_client(self.client_conf) 36 ret = client.upload_by_buffer(content.read()) 37 if ret.get("Status") != "Upload successed.": 38 raise Exception("upload file failed") 39 file_name = ret.get("Remote file_id") 40 return file_name 41 42 def url(self, name): 43 """ 44 返回文件的完整URL路徑 45 :param name: 數據庫中保存的文件名 46 :return: 完整的URL 47 """ 48 return self.base_url + name 49 50 def exists(self, name): 51 """ 52 判斷文件是否存在,FastDFS可以自行解決文件的重名問題 53 所以此處返回False,告訴Django上傳的都是新文件 54 :param name: 文件名 55 :return: False 56 """ 57 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