依赖

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

common/utils/uploads/upyun_uploader.py

@@ -1,4 +1,5 @@
 from base_uploader import BaseUploader
+import upyun
 
 
 class UpyunUploader(BaseUploader):

require/extra.txt

@@ -1,2 +1,4 @@
 Flask-Mail==0.9.1
-celery==5.2.3
+celery==5.2.3
+qiniu==7.5.0
+upyun==2.5.5