From 3c7517be4aaf23d9c66a9317ba91ca62b3d0acb0 Mon Sep 17 00:00:00 2001 From: resonate <1650473152@qq.com> Date: Mon, 24 Jan 2022 13:08:00 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BE=9D=E8=B5=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- common/utils/uploads/qiniu_uploader.py | 19 ++++++++++++++++++- common/utils/uploads/upyun_uploader.py | 1 + require/extra.txt | 4 +++- 3 files changed, 22 insertions(+), 2 deletions(-) diff --git a/common/utils/uploads/qiniu_uploader.py b/common/utils/uploads/qiniu_uploader.py index 00dfe85..640d52e 100644 --- a/common/utils/uploads/qiniu_uploader.py +++ b/common/utils/uploads/qiniu_uploader.py @@ -1,7 +1,15 @@ +from qiniu import Auth, put_data from base_uploader import BaseUploader +access_key = '自己账号的access key' + +secret_key = '自己账号的secret key' + +bucket_name = '空间名' + class QiniuUploader(BaseUploader): + def __init__(self): raise NotImplementedError @@ -9,7 +17,16 @@ class QiniuUploader(BaseUploader): raise NotImplementedError def upload(self, file_obj, filename): - raise NotImplementedError + + token = Auth(access_key=access_key, secret_key=secret_key).upload_token(bucket=bucket_name) + ret, res = put_data(token, None, data=file_obj) + ret.get('key') + print(ret) + print(res) + + if res.status_code != 200: + raise Exception("upload failed") + return ret, res def download(self, filename): raise NotImplementedError diff --git a/common/utils/uploads/upyun_uploader.py b/common/utils/uploads/upyun_uploader.py index 809d5ad..f5af5f7 100644 --- a/common/utils/uploads/upyun_uploader.py +++ b/common/utils/uploads/upyun_uploader.py @@ -1,4 +1,5 @@ from base_uploader import BaseUploader +import upyun class UpyunUploader(BaseUploader): diff --git a/require/extra.txt b/require/extra.txt index 8d30cf8..262b176 100644 --- a/require/extra.txt +++ b/require/extra.txt @@ -1,2 +1,4 @@ Flask-Mail==0.9.1 -celery==5.2.3 \ No newline at end of file +celery==5.2.3 +qiniu==7.5.0 +upyun==2.5.5 \ No newline at end of file