Django 2 1 7 使用go fastdfs上傳文件

時間 2019-11-30

原文原文鏈接

上一篇文章go-fastdfs安裝以及python調用講解了關於go-fastdfs這個開源的分佈式文件存儲系統的安裝以及python上傳文件的方式。html

本篇章來說解繼承到Django2.1.7來進行使用。python

go-fastdfs關於python上傳文件的示例代碼

import requests
url = 'http://10.1.5.9:8080/upload'
files = {'file': open('report.xls', 'rb')}
options={'output':'json','path':'','scene':''} #參閱瀏覽器上傳的選項
r = requests.post(url,data=options, files=files)
print(r.text)
複製代碼

對於這個示例代碼，上一篇在安裝的時候，也進行了測試，也是成功上傳的。下面來看看怎麼在Django寫一個從html的form表單上傳一個單一文件，而後Django後臺將文件上傳到go-fastdfs的流程。web

上傳流程時序圖

在本次示例中，不啓動Go-FastDFS的認證auth_url等等功能，不使用web直接上傳的方式。先以默認Go-FastDFS配置進行上傳示例編寫。數據庫

編寫Django集成使用go-fastdfs示例

1）首先編寫一個上傳文件的html頁面file_upload_fastdfs.htmldjango

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>上傳文件</title>
</head>
<body>
    <form method="post" action="{% url 'assetinfo:fasetdfs_file_upload_handle' %}" enctype="multipart/form-data">
        {%csrf_token%}
        <input type="file" name="file"/><br>
        <input type="submit" value="上傳">
    </form>
</body>
</html>
複製代碼

2）在應用的views.py編寫視圖顯示上傳頁面json

def fastdfs_upload_test(request):
    return render(request, 'assetinfo/file_upload_fastdfs.html')
複製代碼

3）在應用的urls.py編寫請求的url路徑瀏覽器

urlpatterns = [
    # ex:/assetinfo/fastdfs_upload_test
    path('fastdfs_upload_test', views.fastdfs_upload_test, name='fastdfs_upload_test'),
]
複製代碼

4）查看上傳頁面顯示訪問： http://127.0.0.1:8000/assetinfo/fastdfs_upload_testbash

好了，到這裏已經完成了頁面上傳文件的部分，下面繼續寫Django接收請求，並上傳文件至Go-FastDFS的功能。dom

5）在應用的views.py編寫處理上傳文件業務的方法分佈式

def fasetdfs_file_upload_handle(request):
    """接收上傳文件，並上傳至Go-FastDFS文件存儲服務中"""

    file = request.FILES.get('file')
    # 設置保存路徑
    temp_file = '%s/assetinfo/%s' % (settings.MEDIA_ROOT, file.name)
    # 將文件寫入臨時文件
    with open(temp_file, 'wb') as upload_file:
        for c in file.chunks():
            upload_file.write(c)

    # 使用go-fasthttp上傳文件
    import requests
    url = 'http://127.0.0.1:8080/upload' # 上傳go-fasthttp的url路徑
    options = {'output': 'json', 'path': '', 'scene': ''}
    with open(temp_file,'rb') as file: # 以臨時文件path的方式上傳
        r = requests.post(url, data=options, files={'file':file})
        # print(r.text)

    # 解析go-fasthttp返回的上傳結果
    import json
    res_json = json.loads(r.text) # 將go-fastdfs返回的結果轉爲json
    
    # 根據返回的結果，另外將其存儲至數據庫之中，這裏不作數據存儲處理。
    print("url = %s" % res_json['url'])
    print("path = %s" % res_json['path'])
    print("domain = %s" % res_json['domain'])
    print("md5 = %s" % res_json['md5'])

    # 刪除保存在本地路徑的文件 os.remove(path)
    import os
    if os.path.exists(temp_file):
        # 刪除臨時文件
        os.remove(temp_file)

    from django.http.response import JsonResponse
    return JsonResponse({"code": 0})
複製代碼

6）在應用的urls.py配置url

urlpatterns = [
    # ex:/assetinfo/fasetdfs_file_upload_handle
    path('fasetdfs_file_upload_handle', views.fasetdfs_file_upload_handle, name='fasetdfs_file_upload_handle'),
]
複製代碼

7）測試上傳文件

8）查看django後臺打印的信息，確認上傳結果

url = http://127.0.0.1:8080/group1/default/20190820/13/58/2/頭像.jpg
path = /group1/default/20190820/13/58/2/頭像.jpg
domain = http://127.0.0.1:8080
md5 = cf38f0ac32ac608fb87c9bb18fced981
[20/Aug/2019 13:58:44] "POST /assetinfo/fasetdfs_file_upload_handle HTTP/1.1" 200 11
複製代碼

信息正確，功能完成。

9）最後簡單寫一個html視圖，來顯示剛剛上傳的圖片url

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>顯示圖片</title>
</head>
<body>
    <img src="http://127.0.0.1:8080/group1/default/20190820/13/58/2/頭像.jpg">
</body>
</html>
複製代碼

在瀏覽器訪問以下：