devbox
知新_RL
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Python Flask Web框架快速入门

作者：知新_RL | 2024-04-21 11:33:29

赞

踩

Python Flask Web框架快速入门

Flask 入门Demo

Flask 开发环境搭建，执行如下指令：

pip install flask
  1. # 第一节: Flask 快速入门
  2.  
  3. from flask import Flask
  4. app = Flask(__name__)
  5.  
  6.  
  7. @app.route('/flask')
  8. def hello_flask():
  9.    return 'Hello Flask'
  10.  
  11.  
  12. app.run()

核心代码剖析：

从 flask 包导入 Flask 类，通过实例化这个类，创建一个程序对象 app。

app = Flask(__name__)

注册一个处理函数，这个函数是处理某个请求的处理函数，Flask 官方把它叫做视图函数（view funciton）。使用 app.route() 装饰器来为这个函数绑定对应的 URL，当用户在浏览器访问这个 URL 的时候，就会触发这个函数，获取返回值，并把返回值显示到浏览器窗口：

  1. @app.route('/flask')
  2. def hello_flask():
  3.    return 'Hello Flask'

最后，Flask类的run()方法在本地开发服务器上运行应用程序。

app.run(host, port, debug, options)

所有参数都是可选的

序号参数与描述
1

host

要监听的主机名。 默认为127.0.0.1（localhost）。设置为“0.0.0.0”以使服务器在外部可用

2

port

默认值为5000

3

debug

默认为false。 如果设置为true，则提供调试信息

4

options

要转发到底层的Werkzeug服务器。

Flask 基础知识

Flask 入参类型

flask 支持入参数据类型，如下所示：

转换器描述
int整型
float浮点型
path接受用作目录分隔符的斜杠
string默认，字符串
  1. # 第二节: Flask 入参
  2. from flask import Flask, redirect
  3.  
  4. app = Flask(__name__)
  5.  
  6.  
  7. # 字符串入参
  8. @app.route('/strs/<name>')
  9. def strs(name):
  10.     return "Hello %s" % name
  11.  
  12.  
  13. # 浮点数入参
  14. @app.route('/floats/<float:version>')
  15. def floats(version):
  16.     return version
  17.  
  18.  
  19. # 整数入参
  20. @app.route('/ints/<int:version>')
  21. def ints(version):
  22.     return '整数为 %d' % version
  23.  
  24.  
  25. app.run(host='0.0.0.0', port=8888, debug=True)

Flask 重定向(redirect)

url_for()函数用于动态指定函数的URL地址。

  1. # 第三节: Flask 重定向
  2.  
  3. from flask import Flask, redirect, url_for
  4.  
  5. app = Flask(__name__)
  6.  
  7.  
  8. @app.route('/redicts')
  9. def redicts():
  10.     return redirect('https://www.baidu.com')
  11.  
  12.  
  13. @app.route('/admin')
  14. def get_admin():
  15.     return 'Hello Admin'
  16.  
  17.  
  18. @app.route('/guest/<guest>')
  19. def get_guest(guest):
  20.     return 'Hello %s as Guest' % guest
  21.  
  22.  
  23. @app.route('/user/<name>')
  24. def hello_user(name):
  25.     if name == 'admin':
  26.         return redirect(url_for('get_admin'))
  27.     else:
  28.         return redirect(url_for('get_guest', guest=name))
  29.  
  30.  
  31. app.run()

Flask 支持到HTTP方法

默认情况下，Flask路由响应GET请求。但是，可以通过为route()装饰器提供方法参数来更改此首选项。

序号方法与描述
1

GET

以未加密的形式将数据发送到服务器。最常见的方法。

2

HEAD

和GET方法相同，但没有响应体。

3

POST

用于将HTML表单数据发送到服务器。POST方法接收的数据不由服务器缓存。

4

PUT

用上传的内容替换目标资源的所有当前表示。

5

DELETE

删除由URL给出的目标资源的所有当前表示。

  1. # 第四节: Flask 支持HTTP方法
  2.  
  3. from flask import Flask
  4.  
  5. app = Flask(__name__)
  6.  
  7.  
  8. @app.route('/get_request', methods=['GET'])
  9. def get_request():
  10.     return 'GET请求'
  11.  
  12.  
  13. @app.route('/post_request', methods=['POST'])
  14. def post_request():
  15.     return 'POST请求'
  16.  
  17.  
  18. @app.route('/delete_request', methods=['DELETE'])
  19. def delete_request():
  20.     return 'DELETE请求'
  21.  
  22.  
  23. @app.route('/put_request', methods=['PUT'])
  24. def put_request():
  25.     return 'PUT请求'
  26.  
  27.  
  28. @app.route('/head_request', methods=['HEAD'])
  29. def head_request():
  30.     return 'HEAD请求'
  31.  
  32.  
  33. app.run()

 Flask 实战一：模拟用户登入

  1. # Flask 模拟用户登入
  2.  
  3. from flask import Flask, request, jsonify
  4.  
  5. app = Flask(__name__)
  6.  
  7.  
  8. @app.route('/')
  9. def index():
  10.     return '欢迎来到主页'
  11.  
  12.  
  13. @app.route('/login', methods=['POST'])
  14. def login():
  15.     my_json = request.get_json()
  16.     user = my_json.get('user')
  17.     password = my_json.get('password')
  18.     if user == 'admin' and password == '123456':
  19.         # 前端和后端统一请求和返回的数据格式,返回json格式需要导入jsonify这个包
  20.         # return jsonify({
  21.         #     "token": "abcd123456",
  22.         #     "birthday": "2024-04-18"
  23.         # })
  24.         return jsonify(token="abcd123456", birthdat="2024-04-18")
  25.  
  26.  
  27. app.run()

Flask 模板

在项目下创建 templates 文件夹，用于存放所有模板文件，并在目录下创建一个模板文件: login.html 文件

  1. <html>
  2.    <body>
  3.       <form action = "http://localhost:5000/login" method = "post">
  4.          <p>用户名:</p>
  5.          <p><input type = "text" name = "user" /></p>
  6.          <p>密码:</p>
  7.          <p><input type = "password" name = "password" /></p>
  8.          <p><input type = "submit" value = "submit" /></p>
  9.       </form>
  10.    </body>
  11. </html>
  1. # Flask 模拟用户登入 : 基于Template
  2.  
  3. from flask import Flask, request, jsonify, render_template
  4.  
  5. app = Flask(__name__)
  6.  
  7.  
  8. @app.route('/')
  9. def index():
  10.     return render_template("login.html")
  11.  
  12.  
  13. @app.route('/login', methods=['POST'])
  14. def login():
  15.     # 由json 获取修改为表单获取
  16.     user = request.form['user']
  17.     password = request.form['password']
  18.     if user == 'admin' and password == '123456':
  19.         # 前端和后端统一请求和返回的数据格式,返回json格式需要导入jsonify这个包
  20.         # return jsonify({
  21.         #     "token": "abcd123456",
  22.         #     "birthday": "2024-04-18"
  23.         # })
  24.         return jsonify(token="abcd123456", birthdat="2024-04-18")
  25.  
  26.  
  27. app.run()

Flask 模板文件传参

在Python代码中传入字符串，列表，字典到模板中。

  1. from flask import Flask, render_template
  2.  
  3. app = Flask(__name__)
  4.  
  5.  
  6. @app.route('/')
  7. def index():
  8.     # 字符串
  9.     my_str = 'Hello Word'
  10.     # int 类型
  11.     my_int = 10
  12.     # 数组类型
  13.     my_array = [3, 4, 2, 1, 7, 9]
  14.     # 字典类型
  15.     my_dict = {
  16.         'name': 'zhouzhiwengang',
  17.         'age': 31
  18.     }
  19.     return render_template('variable.html',
  20.                            my_str=my_str,
  21.                            my_int=my_int,
  22.                            my_array=my_array,
  23.                            my_dict=my_dict
  24.                            )
  25.  
  26.  
  27. app.run()

Flask 模板文件之静态文件

  1. # 第六节: Flask 模板文件之静态文件
  2. from flask import Flask, render_template
  3.  
  4. app = Flask(__name__)
  5.  
  6.  
  7. @app.route("/")
  8. def index():
  9.     return render_template("static.html")
  10.  
  11.  
  12. app.run(debug=True)

在项目下创建 templates 文件夹，用于存放所有模板文件，并在目录下创建一个模板文件: static.html 文件

  1. <html>
  2.  
  3.    <head>
  4.       <script type = "text/javascript"
  5.          src = "{{ url_for('static', filename = 'static.js') }}" ></script>
  6.    </head>
  7.  
  8.    <body>
  9.       <input type = "button" onclick = "sayHello()" value = "Say Hello" />
  10.    </body>
  11.  
  12. </html>

在项目下创建 static文件夹，用于存放javascript文件或支持网页显示的CSS文件，并在目录下创建一个js文件: static.js文件

  1. function sayHello() {
  2.    alert("Python 模板文件之静态资源文件")
  3. }

Flask Request对象

Request对象的重要属性如下所列：

  • Form - 它是一个字典对象，包含表单参数及其值的键和值对。

  • args - 解析查询字符串的内容，它是问号（？）之后的URL的一部分。

  • Cookies  - 保存Cookie名称和值的字典对象。

  • files - 与上传文件有关的数据。

  • method - 当前请求方法。

  1. # 第七节: Flask Request 对象
  2. # Request对象的重要属性如下所列：
  3. # Form - 它是一个字典对象，包含表单参数及其值的键和值对。
  4. # args - 解析查询字符串的内容，它是问号（？）之后的URL的一部分。
  5. # Cookies  - 保存Cookie名称和值的字典对象。
  6. # files - 与上传文件有关的数据。
  7. # method - 当前请求方法。
  8.  
  9. from flask import Flask, render_template, request
  10.  
  11. app = Flask(__name__)
  12.  
  13.  
  14. @app.route('/')
  15. def student():
  16.     return render_template('student.html')
  17.  
  18.  
  19. @app.route('/result', methods=['POST', 'GET'])
  20. def result():
  21.     if request.method == 'POST':
  22.         result = request.form
  23.         return render_template("result.html", result=result)
  24.  
  25.  
  26. app.run(debug=True)

在项目下创建 templates 文件夹，用于存放所有模板文件，并在目录下创建一个模板文件: student.html /result.html文件

student.html

  1. <html>
  2.    <body>
  3.       <form action="http://localhost:5000/result" method="POST">
  4.         <p>姓名 <input type = "text" name = "Name" /></p>
  5.         <p>物理 <input type = "text" name = "Physics" /></p>
  6.         <p>化学 <input type = "text" name = "chemistry" /></p>
  7.         <p>数学 <input type ="text" name = "Mathematics" /></p>
  8.         <p><input type = "submit" value = "提交" /></p>
  9.    </form>
  10.    </body>
  11. </html>

result.html 

  1. <html>
  2.    <body>
  3.      <table border = 1>
  4.      {% for key, value in result.items() %}
  5.        <tr>
  6.           <th> {{ key }} </th>
  7.           <td> {{ value }}</td>
  8.        </tr>
  9.       {% endfor %}
  10. </table>
  11.    </body>
  12. </html>

Flask Cookie

Cookie以文本文件的形式存储在客户端的计算机上。其目的是记住和跟踪与客户使用相关的数据，以获得更好的访问者体验和网站统计信息。

Cookie 核心方法

设置cookie

默认有效期是临时cookie,浏览器关闭就失效,可以通过 max_age 设置有效期， 单位是秒

  1.  res = make_response('set success')
  2.  res.set_cookie('username', 'zhouzhiwengang', max_age=3600)

获取cookie

通过request.cookies的方式， 返回的是一个字典。

cookie = request.cookies.get('username')

删除cookie

  1.  res = make_response('del success')
  2.  res.delete_cookie('username')
  1. # 第七节: Flask Cookie 对象
  2. from flask import Flask, make_response, request  # 注意需导入 make_response
  3.  
  4. app = Flask(__name__)
  5.  
  6.  
  7. @app.route('/set_cookie')
  8. def set_cookie():
  9.     res = make_response('set success')
  10.     res.set_cookie('username', 'zhouzhiwengang', max_age=3600)
  11.     return res
  12.  
  13.  
  14. @app.route('/get_cookie')
  15. def get_cookie():
  16.     cookie = request.cookies.get('username')
  17.     return cookie
  18.  
  19.  
  20. @app.route('/del_cookie')
  21. def del_cookie():
  22.     res = make_response('del success')
  23.     res.delete_cookie('username')
  24.     return res
  25.  
  26.  
  27. app.run()

Flask Session

与Cookie不同，Session（会话）数据存储在服务器上。会话是客户端登录到服务器并注销服务器的时间间隔。需要在该会话中保存的数据会存储在服务器上的临时目录中。

为每个客户端的会话分配会话ID。会话数据存储在cookie的顶部，服务器以加密方式对其进行签名。对于此加密，Flask应用程序需要一个定义的SECRET_KEY。

Session对象也是一个字典对象，包含会话变量和关联值的键值对。

Session核心方法

设置密钥

app.secret_key = 'abcd12345678'

设置Session会话变量

session['username'] = request.form['username']

删除Session 会话变量

 session.pop('username', None)
  1. # 第八节: Flask Session 对象
  2.  
  3. from flask import Flask, session, redirect, url_for, escape, request
  4.  
  5. app = Flask(__name__)
  6.  
  7. app.secret_key = 'abcd12345678'
  8.  
  9.  
  10. @app.route('/')
  11. def index():
  12.     if 'username' in session:
  13.         # session 会话获取值
  14.         username = session['username']
  15.         return '登录用户名是:' + username + '<br>' + \
  16.                "<b><a href = '/logout'>点击这里注销</a></b>"
  17.  
  18.     return "您暂未登录， <br><a href = '/login'></b>" + \
  19.            "点击这里登录</b></a>"
  20.  
  21.  
  22. @app.route('/login', methods=['GET', 'POST'])
  23. def login():
  24.     if request.method == 'POST':
  25.         user = request.form['username']
  26.         password = request.form['password']
  27.         if user == 'admin' and password == '123456':
  28.             # session 会话设值
  29.             session['username'] = request.form['username']
  30.             return redirect(url_for('index'))
  31.     return '''
  32.    <form action = "" method = "post">
  33.          <p>用户名:</p>
  34.          <p><input type = "text" name = "username" /></p>
  35.          <p>密码:</p>
  36.          <p><input type = "password" name = "password" /></p>
  37.          <p><input type = "submit" value = "submit" /></p>
  38.         <p><input type="submit" value ="登录"/></p>
  39.    </form>
  40.    '''
  41.  
  42.  
  43. @app.route('/logout')
  44. def logout():
  45.     # session 会话移除值
  46.     session.pop('username', None)
  47.     return redirect(url_for('index'))
  48.  
  49.  
  50. if __name__ == '__main__':
  51.     app.run(debug=True)

Flask 错误代码

Flask类具有带有错误代码的abort()函数。

Flask.abort(code)

Code 参数采用以下值之一：

  • 400 - 用于错误请求

  • 401 - 用于未身份验证的

  • 403 - Forbidden

  • 404 - 未找到

  • 406 - 表示不接受

  • 415 - 用于不支持的媒体类型

  • 429 - 请求过多

  1. # 第九节: Flask 错误
  2.  
  3. from flask import Flask, session, redirect, url_for, escape, request, abort
  4.  
  5. app = Flask(__name__)
  6.  
  7. app.secret_key = 'abcd12345678'
  8.  
  9.  
  10. @app.route('/')
  11. def index():
  12.     if 'username' in session:
  13.         # session 会话获取值
  14.         username = session['username']
  15.         return '登录用户名是:' + username + '<br>' + \
  16.                "<b><a href = '/logout'>点击这里注销</a></b>"
  17.  
  18.     return "您暂未登录， <br><a href = '/login'></b>" + \
  19.            "点击这里登录</b></a>"
  20.  
  21.  
  22. @app.route('/login', methods=['GET', 'POST'])
  23. def login():
  24.     if request.method == 'POST':
  25.         user = request.form['username']
  26.         password = request.form['password']
  27.         if user == 'admin' and password == '123456':
  28.             # session 会话设值
  29.             session['username'] = request.form['username']
  30.             return redirect(url_for('index'))
  31.         else:
  32.             # 用户验证不通过
  33.             abort(401)
  34.     return '''
  35.    <form action = "" method = "post">
  36.          <p>用户名:</p>
  37.          <p><input type = "text" name = "username" /></p>
  38.          <p>密码:</p>
  39.          <p><input type = "password" name = "password" /></p>
  40.          <p><input type = "submit" value = "submit" /></p>
  41.         <p><input type="submit" value ="登录"/></p>
  42.    </form>
  43.    '''
  44.  
  45.  
  46. @app.route('/logout')
  47. def logout():
  48.     # session 会话移除值
  49.     session.pop('username', None)
  50.     return redirect(url_for('index'))
  51.  
  52.  
  53. if __name__ == '__main__':
  54.     app.run(debug=True)

Flask 消息反馈

Flask 模块包含 flash() 方法。它将后端处理消息传递给前端。

  1. # 第十节: Flask 消息反馈
  2.  
  3. from flask import Flask, redirect, url_for, request, render_template, flash
  4.  
  5. app = Flask(__name__)
  6. # seesion 会话存储临时目录地址
  7. app.secret_key = 'abcde'
  8.  
  9.  
  10. @app.route('/')
  11. def index():
  12.     return render_template('response.html')
  13.  
  14.  
  15. @app.route('/login', methods=['GET', 'POST'])
  16. def login():
  17.     error = None
  18.     if request.method == 'POST':
  19.         user = request.form['user']
  20.         password = request.form['password']
  21.         if user == 'admin' and password == '123456':
  22.             flash('登入成功')
  23.             return redirect(url_for('index'))
  24.         else:
  25.             # 用户验证不通过,反馈相关信息
  26.             error = '非法用户名或密码,请重新登入'
  27.     return render_template('login.html', error=error)
  28.  
  29.  
  30. if __name__ == '__main__':
  31.     app.run(debug=True)

在项目下创建 templates 文件夹，用于存放所有模板文件，并在目录下创建一个模板文件: login.html /response.html文件

login.html

  1. <html>
  2.    <body>
  3.       <form action = "http://localhost:5000/login" method = "post">
  4.          <p>用户名:</p>
  5.          <p><input type = "text" name = "user" /></p>
  6.          <p>密码:</p>
  7.          <p><input type = "password" name = "password" /></p>
  8.          <p><input type = "submit" value = "submit" /></p>
  9.       </form>
  10.       {% if error %}
  11.          <p><strong>错误信息</strong>: {{ error }}</p>
  12.       {% endif %}
  13.    </body>
  14. </html>

response.html

  1. <!DOCTYPE html>
  2. <html lang="en">
  3. <head>
  4.     <meta charset="UTF-8">
  5.     <title>Flask 消息反馈</title>
  6. </head>
  7. <body>
  8.     {% with messages = get_flashed_messages() %}
  9.          {% if messages %}
  10.                {% for message in messages %}
  11.                     <p>{{ message }}</p>
  12.                {% endfor %}
  13.          {% endif %}
  14.     {% endwith %}
  15. <h3>Welcome!</h3>
  16. <a href = "{{ url_for('login') }}">登入</a>
  17. </body>
  18. </html>

Flask 文件上传

在 Flask 中处理文件上传非常简单。它需要一个 HTML 表单，其 ​enctype​ 属性设置为“​multipart/form-data”​，将文件发布到 URL。

URL 处理程序从 ​request.files[]​ 对象中提取文件，并将其保存到所需的位置。

每个上传的文件首先会保存在服务器上的临时位置，然后将其实际保存到它的最终位置。

目标文件的名称可以是硬编码的，也可以从 ​request.files[file] ​对象的​ filename ​属性中获取。但是，建议使用 ​secure_filename()​ 函数获取它的安全版本。

可以在 Flask 对象的配置设置中定义默认上传文件夹的路径和上传文件的最大大小。

  1. app.config['UPLOAD_FOLDER'] 定义上传文件夹的路径 
  2.  
  3. app.config['MAX_CONTENT_LENGTH'] 指定要上传的文件的最大大小（以字节为单位）
  1. # 第十一节: Flask 文件上传
  2.  
  3. from flask import Flask, render_template, request
  4. from werkzeug.utils import secure_filename
  5.  
  6. import os
  7.  
  8. app = Flask(__name__)
  9. UPLOAD_FOLDER = 'upload'
  10. if not os.path.exists(UPLOAD_FOLDER):
  11.     os.makedirs(UPLOAD_FOLDER)
  12. app.config['UPLOAD_FOLDER'] = UPLOAD_FOLDER
  13.  
  14.  
  15. @app.route('/upload')
  16. def upload_file():
  17.     return render_template('upload.html')
  18.  
  19.  
  20. @app.route('/uploader', methods=['GET', 'POST'])
  21. def uploader():
  22.     if request.method == 'POST':
  23.         f = request.files['file']
  24.         print(request.files)
  25.         f.save(os.path.join(app.config['UPLOAD_FOLDER'], secure_filename(f.filename)))
  26.         return '文件上传成功'
  27.     else:
  28.         return render_template('upload.html')
  29.  
  30.  
  31. if __name__ == '__main__':
  32.    app.run(debug=True)

Flask 拓展

Flask常用扩展包：

Flask-SQLalchemy：操作数据库；

Flask-script：插入脚本；

Flask-migrate：管理迁移数据库；

Flask-Session：Session存储方式指定；

Flask-WTF：表单；

Flask-Mail：邮件；

Flask-Bable：提供国际化和本地化支持，翻译；

Flask-Login：认证用户状态；

Flask-OpenID：认证；

Flask-RESTful：开发REST API的工具；

Flask-Bootstrap：集成前端Twitter Bootstrap框架；

Flask-Moment：本地化日期和时间；

Flask-Admin：简单而可扩展的管理接口的框架

Flask 拓展之Flask-SQLalchemy

SQLAlchemy是一个关系型数据库框架，它提供了高层的ORM和底层的原生数据库的操作。flask-sqlalchemy是一个简化了SQLAlchemy操作的flask扩展。

安装flask-sqlalchemy扩展, 执行如下指令:
  1. pip install -U Flask-SQLAlchemy
  2.  
  3. pip install flask-mysqldb
  4.  
  5. pip install pymysql
SQLAlchemy支持字段类型
类型名python中类型说明
Integerint普通整数，一般是32位
SmallIntegerint取值范围小的整数，一般是16位
BigIntegerint或long不限制精度的整数
Floatfloat浮点数
Numericdecimal.Decimal普通整数，一般是32位
Stringstr变长字符串
Textstr变长字符串，对较长或不限长度的字符串做了优化
Unicodeunicode变长Unicode字符串
UnicodeTextunicode变长Unicode字符串，对较长或不限长度的字符串做了优化
Booleanbool布尔值
Datedatetime.date时间
Timedatetime.datetime日期和时间
LargeBinarystr二进制文件
SQLAlchemy列选项
选项名说明
primary_key如果为True，代表表的主键
unique如果为True，代表这列不允许出现重复的值
index如果为True，为这列创建索引，提高查询效率
nullable如果为True，允许有空值，如果为False，不允许有空值
default为这列定义默认值
SQLAlchemy关系选项
选项名说明
backref在关系的另一模型中添加反向引用
primary join明确指定两个模型之间使用的联结条件
uselist如果为False，不使用列表，而使用标量值
order_by指定关系中记录的排序方式
secondary指定多对多中记录的排序方式
secondary join在SQLAlchemy中无法自行决定时，指定多对多关系中的二级联结条件
Flask-SQLalchemy 实战之快速入门
  1. # 第十一节: Flask 拓展之数据库(flask-sqlalchemy), 快速入门
  2. # 导入Flask及相关扩展库
  3. from flask import Flask
  4. from flask_sqlalchemy import SQLAlchemy
  5.  
  6. # 创建Flask应用实例
  7. app = Flask(__name__)
  8.  
  9. # 配置MySQL数据库连接
  10. app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:123456@192.168.43.10/house'
  11. db = SQLAlchemy(app)
  12.  
  13.  
  14. # 定义ORM模型，表示数据库表
  15. class Table(db.Model):
  16.     __tablename__ = 'base_house'
  17.     id = db.Column(db.String(255), primary_key=True)
  18.  
  19.  
  20. # 路由函数，查询库下所有表名，并返回
  21. @app.route('/')
  22. def get_tables():
  23.     tables = Table.query.all()
  24.     house_list = []
  25.     for user in tables:
  26.         user_data = {
  27.             'id': user.id
  28.         }
  29.         house_list.append(user_data)
  30.     return {'users': house_list}
  31.  
  32.  
  33. if __name__ == '__main__':
  34.     app.run()
Flask-SQLalchemy 实战之分页查询和参数筛选
  1. # 第十一节: Flask 拓展之数据库(flask-sqlalchemy), 分页 + 入参查询
  2. # 导入Flask及相关扩展库
  3. from flask import Flask, request, jsonify
  4. from flask_sqlalchemy import SQLAlchemy
  5.  
  6. # 创建Flask应用实例
  7. app = Flask(__name__)
  8.  
  9. # 配置MySQL数据库连接
  10. app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:123456@192.168.43.10/house'
  11. db = SQLAlchemy(app)
  12.  
  13.  
  14. # 定义ORM模型，表示数据库表
  15. class Table(db.Model):
  16.     __tablename__ = 'base_house'
  17.     id = db.Column(db.String(255), primary_key=True)
  18.     project_no = db.Column(db.String(255))
  19.     project_name = db.Column(db.String(255))
  20.     project_address = db.Column(db.String(255))
  21.  
  22.  
  23. # 路由函数，查询库下所有表名，并返回
  24. @app.route('/', methods=['POST'])
  25. def get_tables():
  26.     parame_json = request.get_json()
  27.     page = parame_json.get('page')
  28.     size = parame_json.get('size')
  29.     name = parame_json.get('name')
  30.  
  31.     if name:
  32.         houses = Table.query.filter_by(project_name=name).paginate(page=page, per_page=size, error_out=False)
  33.     else:
  34.         houses = Table.query.paginate(page=page, per_page=size, error_out=False)
  35.  
  36.     house_list = []
  37.     for house in houses:
  38.         house_data = {
  39.             'id': house.id,
  40.             'projectNo': house.project_no,
  41.             'projectName': house.project_name,
  42.             'projectAddress': house.project_address
  43.         }
  44.         house_list.append(house_data)
  45.     return jsonify({
  46.         'users': house_list,
  47.         'total_pages': houses.pages,
  48.         'current_page': houses.page
  49.     })
  50.  
  51.  
  52. if __name__ == '__main__':
  53.     app.run()

涉及base_house 表DDL：

  1. CREATE TABLE `base_house` (
  2.   `id` varchar(64) NOT NULL,
  3.   `project_no` varchar(128) DEFAULT NULL,
  4.   `project_name` varchar(256) DEFAULT NULL,
  5.   `project_address` varchar(256) DEFAULT NULL,
  6.   PRIMARY KEY (`id`)
  7. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

Flask 拓展之Flask-Login

扩展 Flask-Login 提供了实现用户认证需要的各类功能函数，我们将使用它来实现程序的用户认证，首先来安装它：

pip install flask-login

app.py：初始化 Flask-Login

  1. from flask_login import LoginManager
  2.  
  3. login_manager = LoginManager(app)  # 实例化扩展类
  4.  
  5. @login_manager.user_loader
  6. def load_user(user_id):  # 创建用户加载回调函数，接受用户 ID 作为参数
  7.     user = User.query.get(int(user_id))  # 用 ID 作为 User 模型的主键查询对应的用户
  8.     return user  # 返回用户对象

Table模型类继承 Flask-Login 提供的 UserMixin 类：

  1. # 定义ORM模型，表示数据库表
  2. class Table(UserMixin, db.Model):
  3.     __tablename__ = 't_admin'
  4.     id = db.Column(db.Integer, primary_key=True)
  5.     username = db.Column(db.String(30))
  6.     userpwd = db.Column(db.String(100))

 

  1. # 第十二节: Flask 拓展之数据库(flask-sqlalchemy)/认证框架(flask-login), 使用用户登入并方法鉴权
  2. from flask import Flask, request, jsonify, redirect, url_for, render_template
  3. from flask_sqlalchemy import SQLAlchemy
  4. from flask_login import LoginManager, UserMixin, login_user, login_required, logout_user
  5.  
  6.  
  7. # 创建Flask应用实例
  8. app = Flask(__name__)
  9. # seesion 会话存储临时目录地址
  10. app.secret_key = 'abcde1234'
  11.  
  12. # 配置MySQL数据库连接
  13. app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:123456@192.168.43.10/house'
  14. db = SQLAlchemy(app)
  15.  
  16. # 初始化登录管理器
  17. login_manager = LoginManager()
  18. login_manager.init_app(app)
  19.  
  20.  
  21. # 定义ORM模型，表示数据库表
  22. class Table(UserMixin, db.Model):
  23.     __tablename__ = 't_admin'
  24.     id = db.Column(db.Integer, primary_key=True)
  25.     username = db.Column(db.String(30))
  26.     userpwd = db.Column(db.String(100))
  27.  
  28.  
  29. # 加载用户的回调函数
  30. @login_manager.user_loader
  31. def load_user(user_id):
  32.     return Table.query.get(int(user_id))
  33.  
  34.  
  35. # 定义登录路由
  36. @app.route('/login', methods=['GET', 'POST'])
  37. def login():
  38.     if request.method == 'POST':
  39.         username = request.form['username']
  40.         password = request.form['password']
  41.         user = Table.query.filter_by(username=username).first()
  42.         if user and user.userpwd == password:
  43.             login_user(user)
  44.             return redirect(url_for('dashboard'))
  45.     return render_template('auth_login.html')
  46.  
  47.  
  48. # 定义需要鉴权的页面
  49. @app.route('/dashboard')
  50. @login_required
  51. def dashboard():
  52.     return render_template('dashboard.html')
  53.  
  54.  
  55. # 定义登出路由
  56. @app.route('/logout')
  57. @login_required
  58. def logout():
  59.     logout_user()
  60.     return redirect(url_for('login'))
  61.  
  62.  
  63. if __name__ == '__main__':
  64.     app.run()

Flask 拓展之Flask-JWT-Extended

JWT简介

具体原理请参考：JSON Web Token 入门教程

JWT结构

JWT由三部分组成：

  • 头部（Header）：通常包含令牌的类型（JWT）和使用的加密算法。
  • 载荷（Payload）：包含有关用户或其他数据的信息。例如，用户ID、角色或其他自定义数据。
  • 签名（Signature）：由头部、载荷和密钥组合而成的签名，用于验证令牌的完整性和来源可信度。

JWT生成和校验

  1. 用户登录时，服务器使用密钥签署JWT，并将其返回给客户端。
  2. 客户端在以后的请求中发送JWT作为身份验证令牌。
  3. 服务器验证JWT的签名以确保其完整性，然后使用载荷中的信息进行用户身份验证和授权。

Flask-JWT-Extended 

Flask-JWT-Extended是一个Python库，用于在 Flask 应用程序中添加JSON Web令牌（JWT）支持。它是一个插件，可以通过安装它来扩展Flask应用程序的功能。

官网地址：Flask-JWT_Extended 官网

Flask-JWT-Extended 安装

pip install Flask-JWT-Extended

实战：Flask-SQLalchemy + MySQL 8  + Flask-JWT-Extended 实现前后端分离用户认证和鉴权。

  1. # _*_ coding : UTF-8_*_
  2. # 开发者 ： zhuozhiwengang
  3. # 开发时间 : 2024/4/19 9:26
  4. # 文件名称 : 19
  5. # 开发工具 : PyCharm
  6. # 第十二节: Flask 拓展之数据库(flask-sqlalchemy)/认证框架(flask-jwt-extend), 实现用户前后端分离认证和鉴权
  7. from flask import Flask, request, jsonify, redirect, url_for, render_template, abort
  8. from flask_sqlalchemy import SQLAlchemy
  9. from flask_jwt_extended import (JWTManager, jwt_required, create_access_token, get_jwt_identity)
  10.  
  11.  
  12. # 创建Flask应用实例
  13. app = Flask(__name__)
  14. # 用于签名JWT的密钥
  15. app.config['JWT_SECRET_KEY'] = 'abc123'
  16.  
  17. # 配置MySQL数据库连接
  18. app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:123456@192.168.43.10/house'
  19. db = SQLAlchemy(app)
  20.  
  21. # 初始化JWT扩展
  22. jwt = JWTManager(app)
  23.  
  24.  
  25. # 定义ORM模型，表示数据库表
  26. class Table(db.Model):
  27.     __tablename__ = 't_admin'
  28.     id = db.Column(db.Integer, primary_key=True)
  29.     username = db.Column(db.String(30))
  30.     userpwd = db.Column(db.String(100))
  31.  
  32.  
  33. # 定义登录路由
  34. @app.route('/login', methods=['GET', 'POST'])
  35. def login():
  36.     if request.method == 'POST':
  37.         username = request.form['username']
  38.         password = request.form['password']
  39.         user = Table.query.filter_by(username=username).first()
  40.         if user and user.userpwd == password:
  41.             access_token = create_access_token(identity=username)
  42.             return jsonify(access_token=access_token)
  43.         else:
  44.             # 用户名或密码错误
  45.             abort(401)
  46.  
  47.  
  48. # 定义需要鉴权的页面
  49. @app.route('/dashboard')
  50. @jwt_required()  # 这个装饰器要求请求必须携带有效的JWT令牌
  51. def dashboard():
  52.     # 使用get_jwt_identity访问当前用户的身份
  53.     current_user = get_jwt_identity()
  54.     return jsonify(logged_in_as=current_user)
  55.  
  56.  
  57. if __name__ == '__main__':
  58.     app.run()

第一种情况：输入错误用户名或密码，提示401错误代码

控制台输出信息：

  1. WARNING: This is a development server. Do not use it in a production deployment. Use a production WSGI server instead.
  2.  * Running on http://127.0.0.1:5000
  3. Press CTRL+C to quit
  4. 127.0.0.1 - - [19/Apr/2024 09:36:45] "POST /login HTTP/1.1" 401 -

 第二种情况：输入正确用户名和密码，获取凭证Token

 第三种情况：拼接头信息，访问受保护资源

Flask-JWT-Extended 核心代码讲解 

初始化

  1. from flask import Flask
  2. from flask_jwt_extended import (JWTManager, jwt_required, create_access_token, get_jwt_identity)
  3.  
  4. app = Flask(__name__)
  5. # 用于签名JWT的密钥
  6. app.config['JWT_SECRET_KEY'] = 'your-secret-key' 
  7.  
  8. # 初始化JWT扩展
  9. jwt = JWTManager(app)

生成和校验

  • 定义了 /login 路由，用于用户登录并获取JWT令牌。在这个路由中，首先从请求中获取用户名和密码（这里是 “zzg” 和 “123456”）。如果匹配成功，就使用 create_access_token 函数生成JWT令牌，并返回给客户端。
  • 定义了 /protected 路由，它是受保护的路由，只有在请求中包含有效的JWT令牌时才能访问。这是通过 @jwt_required() 装饰器实现的。
    • 如果请求中没有有效的JWT令牌，访问该路由会返回未授权的响应。
    • 如果令牌有效，路由会使用 get_jwt_identity() 函数获取JWT中的身份信息（在示例中为用户名）然后返回一个JSON响应，显示已登录的用户

 Flask-JWT-Extended 优化：设置Token有效期、刷新Token

设置Token有效期

设置JWT的过期时间是一种重要的安全措施，可以帮助确保令牌不会无限期有效，提高了应用程序的安全性。

方法一：

使用 app.config['JWT_ACCESS_TOKEN_EXPIRES'] 来设置JWT的访问token默认过期时间为1小时。

  1. # 设置ACCESS_TOKEN的默认过期时间为1小时
  2. app.config['JWT_ACCESS_TOKEN_EXPIRES'] = timedelta(hours=1)

方法二：

当使用create_access_token函数创建JWT令牌时，也可以通过传递expires_delta参数来覆盖默认的过期时间，例如：

  • 这将覆盖默认的过期时间，使得令牌在30分钟后过期。
  1. from datetime import timedelta
  2. # 设置ACCESS_TOKEN的默认过期时间为30分钟
  3. access_token = create_access_token(identity=username, expires_delta=timedelta(minutes=30))

刷新Token 

认证Token与刷新Token差异

访问token（Access Token）刷新token（Refresh Token）
用途用于访问受保护的资源用于获取新的访问token
生命周期默认为15分钟默认为30天
显式指定生命周期JWT_ACCESS_TOKEN_EXPIRESJWT_REFRESH_TOKEN_EXPIRES
储存方式在请求的头信息（Header）中的 “Authorization” 字段中一般存储在服务器端的数据库

每个用户生成的刷新token和访问token是一一对应的，

当用户登录成功后，服务器会为该用户生成一对刷新token和访问token，并将它们关联到用户的身份（通常是用户的用户名或ID）。这样，每个用户都有自己唯一的刷新token和访问token。

刷新token用于获取新的访问token，以延长用户的会话时间。只有拥有有效的刷新token的用户才能获取新的访问token，而访问token则用于实际访问受保护的资源。

实战：Flask-SQLalchemy + MySQL 8  + Flask-JWT-Extended 实现前后端分离用户认证和鉴权。添加刷新Token和使用刷新Token鉴权。

  1. # 第十二节: Flask 拓展之数据库(flask-sqlalchemy)/认证框架(flask-jwt-extend), 实现用户前后端分离认证和鉴权
  2. from flask import Flask, request, jsonify, redirect, url_for, render_template, abort
  3. from flask_sqlalchemy import SQLAlchemy
  4. from flask_jwt_extended import (JWTManager, jwt_required, create_access_token, get_jwt_identity, create_refresh_token)
  5.  
  6.  
  7. # 创建Flask应用实例
  8. app = Flask(__name__)
  9. # 用于签名JWT的密钥
  10. app.config['JWT_SECRET_KEY'] = 'abc123'
  11.  
  12. # 配置MySQL数据库连接
  13. app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:123456@192.168.43.10/house'
  14. db = SQLAlchemy(app)
  15.  
  16. # 初始化JWT扩展
  17. jwt = JWTManager(app)
  18.  
  19.  
  20. # 定义ORM模型，表示数据库表
  21. class Table(db.Model):
  22.     __tablename__ = 't_admin'
  23.     id = db.Column(db.Integer, primary_key=True)
  24.     username = db.Column(db.String(30))
  25.     userpwd = db.Column(db.String(100))
  26.  
  27.  
  28. # 定义登录路由
  29. @app.route('/login', methods=['GET', 'POST'])
  30. def login():
  31.     if request.method == 'POST':
  32.         username = request.form['username']
  33.         password = request.form['password']
  34.         user = Table.query.filter_by(username=username).first()
  35.         if user and user.userpwd == password:
  36.             access_token = create_access_token(identity=username)
  37.             refresh_token = create_refresh_token(identity=username)
  38.             return jsonify(access_token=access_token, refresh_token=refresh_token)
  39.         else:
  40.             # 用户名或密码错误
  41.             abort(401)
  42.  
  43.  
  44. # 使用刷新token获取新的访问token
  45. @app.route("/refresh", methods=["POST"])
  46. @jwt_required(refresh=True)  # 使用刷新token进行验证
  47. def refresh():
  48.     current_user = get_jwt_identity()
  49.     access_token = create_access_token(identity=current_user)
  50.     return jsonify(access_token=access_token)
  51.  
  52.  
  53. # 定义需要鉴权的页面
  54. @app.route('/dashboard')
  55. @jwt_required()  # 这个装饰器要求请求必须携带有效的JWT令牌
  56. def dashboard():
  57.     # 使用get_jwt_identity访问当前用户的身份
  58.     current_user = get_jwt_identity()
  59.     return jsonify(logged_in_as=current_user)
  60.  
  61.  
  62. if __name__ == '__main__':
  63.     app.run()

相关截图：

Flask 拓展之flask_restful 

flask_restful安装

pip install flask_restful

实战：Flask-SQLalchemy + MySQL 8 +Flask_Restful 实现Restful 接口

  1. from flask import Flask, request, jsonify
  2. from flask_restful import Api, Resource
  3. from flask_sqlalchemy import SQLAlchemy
  4.  
  5. # 创建Flask应用实例
  6. app = Flask(__name__)
  7.  
  8. # 配置MySQL数据库连接
  9. app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:123456@192.168.43.10/house'
  10. db = SQLAlchemy(app)
  11. api = Api(app)
  12.  
  13.  
  14. # 定义ORM模型，表示数据库表
  15. class Table(db.Model):
  16.     __tablename__ = 'base_house'
  17.     id = db.Column(db.String(255), primary_key=True)
  18.     project_no = db.Column(db.String(255))
  19.     project_name = db.Column(db.String(255))
  20.     project_address = db.Column(db.String(255))
  21.  
  22.  
  23. class UserAPI(Resource):
  24.     def get(self, user_id):
  25.         user = Table.query.get(user_id)
  26.         if user:
  27.             return {'id': user.id, 'projectNo': user.project_no, 'projectName': user.project_name, 'projectAddress': user.project_address}
  28.         else:
  29.             return {'message': 'House not found'}, 404
  30.  
  31.     def post(self):
  32.         data = request.get_json()
  33.         new_user = Table(project_no=data['projectNo'], project_name=data['projectName'], project_address=data['projectAddress'], id=data['id'])
  34.         db.session.add(new_user)
  35.         db.session.commit()
  36.         return {'message': '创建成功'}, 201
  37.  
  38.     def delete(self, user_id):
  39.         user = Table.query.get(user_id)
  40.         if user:
  41.             db.session.delete(user)
  42.             db.session.commit()
  43.             return {'message': '删除成功'}
  44.         else:
  45.             return {'message': '记录未找到'}, 404
  46.  
  47.  
  48. api.add_resource(UserAPI, '/user', '/user/<user_id>')
  49.  
  50. if __name__ == '__main__':
  51.     app.run(port=8081)

Flask 高级

待补充Flask高级内容主要涉及：Python 多线程、Python连接Redis、Python连接MongoDB、Python 连接Elasticsearch、Python MinoIO 文件服务器。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/知新_RL/article/detail/462772
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号