Flag decodes token, mounts token, decorator, and seven cattle cloud upload

Create a utils/JwtTools.py Folder

import jwt
class JwtTool():
    def valid(self, token):

        secret_key = current_app.config.get('SECRET_KEY')
        try:
            time.sleep(2)
            payload = jwt.decode(token, secret_key, algorithms='HS256')
            print(payload)
            return payload
        except Exception as e:
            print(e)
            return False

Write login logic

#  Mount before request 
@user_bp.before_request
def gz():
    req = reqparse.RequestParser()
    req.add_argument('token', default='', location='headers')
    args = req.parse_args()
    token = args['token']

    payload = JwtTool().valid(token)
    print('========', payload)

    if not payload:
        uid = 0
    else:
        uid = payload['id']
    g.uid = uid


#  Decorator 
def login(func):
    def warpper(*args, **kwargs):
    
        print(' Detect login ')
        if not g.uid:
            return jsonify({
    'code': 403, 'msg': ' User not registered '})
            
        return func(*args, **kwargs)
    return warpper


class UserView(Resource):
    @login
    def get(self):
        user_info = UserModel.query.get(g.uid)

        return jsonify({
    
            'code': 200,
            'msg': ' User information obtained successfully ',
            'data': {
    
                'username': user_info.username,
                'img': user_info.img
            }
        })
api.add_resource(UserView, '/user')        

A simple logic of uploading pictures

class UploadView(Resource):
    def post(self):
        key = '1.jpg'
        ak = 'qIpsogKsnioK63SvhCDMp*************OGOW4_'
        sk = 'Gmg0YLb5QKzQYxAH2Dspi**************U43L5'

        q = Auth(ak, sk)
        bucket = 'h2111p7123'
        token = q.upload_token(bucket, key, 3600)

        res = put_file(token, key, './static/1.jpg', version='v2')

        if res[0]['key'] == key:
            return jsonify({
    'code': 200, 'msg': ' Upload successful '})
        return jsonify({
    'code': 400, 'msg': ' Upload failed '})

api.add_resource(UploadView, '/upload')

Package seven cattle cloud upload method

1. Create a utils/QiniuTooks.py File write code

from qiniu import Auth, put_file
from flask import current_app


class QiniuTool():
    def __init__(self):
        ak = current_app.config.get('QINIU_AK')
        sk = current_app.config.get('QINIU_SK')

        self.q = Auth(ak, sk)
        self.bucket_name = current_app.config.get('QINIU_BUCHET_NAME')

    def upload(self, localfilepath, newfilename):
        """  To upload pictures  :param localfilepath:  Picture path  :param newfilename:  The name of the uploaded picture  :return: """
        token = self.q.upload_token(self.bucket_name, newfilename, 3600)
        ser = put_file(token, newfilename, localfilepath, version='v2')
        if ser[0]['key'] == newfilename:
            return newfilename
        return False



if __name__ == '__main__':
    from app import app
    with app.app_context():
        QiniuTool().upload('./../static/1.jpg', 'static/img/1.jpg')

2. Called in the view

from datetime import datetime
from utils.QiniuTools import QiniuTool


class UploadView(Resource):
    def post(self):
		#  Get the files that need to be uploaded  
		img = request.files.get('img')
        #  Get the suffix of the picture 
        ext = img.filename.split('.')[-1]
        
        #  Get the timestamp and splice 
        now_time = datetime.strftime(datetime.now(), '%Y%m%d%H%M%S')
        new_name = f'{
      now_time + str(random.randint(1000,9999))}.{
      ext}'
        # print(new_name)
        #  The splicing route is saved locally 
        save_path = f'static/{
      new_name}'
        img.save(save_path)
        
        #  Upload to qiniuyun 
        res = QiniuTool().upload(save_path, save_path)
        if not res:
            return jsonify({
    'code': 400, 'msg': ' Upload failed '})

        #  Save to database 
        user_info = UserModel.query.get(g.uid)
        user_info.img = save_path
        db.session.commit()

        return jsonify({
    'code': 200, 'msg': ' Upload successful ', 'data': save_path})


api.add_resource(UploadView, '/upload')