首页 > 其他分享 >flask-03

flask-03

时间:2022-12-12 22:00:12浏览次数:45  
标签:03 flask app request session cookie print self

一、请求与响应

1.1请求对象

请求对象是全局的,需要导入,这个全局的request。在哪个视图函数中,就是当次的request对象不会乱

def index():
    # request.method  提交的方法
    print(request.method)
    # request.args  get请求提及的数据
    print(request.args)
    print(request.args.get('name'))
    # request.form   post请求提交的数据
    print(request.form)
    # request.values  post和get提交的数据总和
    print(request.values)
    # request.cookies  客户端所带的cookie
    print(request.cookies)
    # request.headers  请求头
    print(request.headers)
    # request.path     不带域名,请求路径
    print(request.path)
    # request.full_path  不带域名,带参数的请求路径
    print(request.full_path)
    # request.script_root
    print('服务端:', request.script_root)
    # request.url           带域名带参数的请求路径
    print(request.url)
    # request.base_url		带域名请求路径
    print(request.base_url)
    # request.url_root      域名
    print(request.url_root)
    # request.host_url		域名
    print(request.host_url)
    # request.host			127.0.0.1:500
    print(request.host)
    # request.files
    print(request.files)
    # obj = request.files['files']
    # obj.save('./xx.jpg')

    print(request.data) # django的body
    return 'hellod'

 1.2响应对象

  • return的4件套render_templateredirectjsonify''(字符串)
  • make_response:把框架返回的东西判断是不是response对象,不是的话它会帮你转换成response对象
  • 然后就可以往Response的对象中,放入响应头
from flask import Flask, request, render_template, redirect, jsonify, make_response

app = Flask(__name__)
app.debug = True

@app.route('/', methods=['GET', 'POST'])
def index():
    # 1四件套
    # -render_template
    # -redirect
    # -jsonify
    # -''
    # 2写入响应头-->没有响应对象,先做出一个响应对象
    # from .wrappers import Response
    res = 'helloe'
    res = make_response(res)
    # 往Response的对象中,放入响应头
    res.headers['name'] = 'lqz'
    # 3 写入cookie
    # res.set_cookie('xx','xx')
    res.delete_cookie('xx')
    return res


if __name__ == '__main__':
    app.run()
    '''
    key, 键
    value=’’, 值
    max_age=None, 超时时间 cookie需要延续的时间(以秒为单位)如果参数是\ None`` ,这个cookie会延续到浏览器关闭为止
    expires=None, 超时时间(IE requires expires, so set it if hasn’t been already.)
    path=’/‘, Cookie生效的路径,/ 表示根路径,特殊的:根路径的cookie可以被任何url的页面访问,浏览器只会把cookie回传给带有该路径的页面,这样可以避免将cookie传给站点中的其他的应用。
    domain=None, Cookie生效的域名 你可用这个参数来构造一个跨站cookie。如, domain=”.example.com”所构造的cookie对下面这些站点都是可读的:www.example.com 、 www2.example.com 和an.other.sub.domain.example.com 。如果该参数设置为 None ,cookie只能由设置它的站点读取
    secure=False, 浏览器将通过HTTPS来回传cookie
    httponly=False 只能http协议传输,无法被JavaScript获取(不是绝对,底层抓包可以获取到也可以被覆盖)
    '''

 1.3前后端分离和混合

前后端混合,cookie是后端写入的

  • res.set_cookie('xx','xx') 混合都是这么写的,这样写了,浏览就会把cookie保存到cookie中
  • 本质是后端把cookie放到响应头中,浏览器读到响应头中有cookie,把cookie写入到浏览器中

前后端分离后,不写cookie了

  • 直接把客户端要存到cookie中的数据,放到响应体中
  • 前端(浏览器,app,小程序),自己取出来,放到相应的位置
    • 浏览器使用js自己写入到cookie
    • app 自己使用代码写入到某个位置

 二、session的使用和原理

cookie:存在客户端浏览器的键值对

session:存在服务器的键值对

  • 用session的认证机制可以统计在线人数

 

 放值 视图函数中

  • 导入全局的session  session['name']='curry'

取值 视图函数中

  • 导入全局的session   print(session['name'])

2.1源码分析

 django 的这一套都在rom django.contrib.sessions.middleware import SessionMiddleware

flask 在flask源码中

  • 请求来了,会执行 app()

整个flask,从请求进来,到请求走的整个流程

  • 执行ctx.push()
    def wsgi_app(self, environ, start_response):
        ctx = self.request_context(environ)
        try:
            try:
                ctx.push() # 它的源码
                response = self.full_dispatch_request()
            except Exception as e:
                error = e
                response = self.handle_exception(e)
            except: 
                error = sys.exc_info()[1]
                raise
            return response(environ, start_response)
        finally:
            ctx.pop(error)

ctx.push的源码373行左右

if self.session is None:
    session_interface = self.app.session_interface
    self.session = session_interface.open_session(self.app, self.request)
    if self.session is None:
        self.session = session_interface.make_null_session(self.app)

app.session_interface  就是Flask对象中有个session_interface对象

SecureCookieSessionInterface()
    -open_session:请求来了,从cookie中取出三段串,反序列化解密放到session中
    -save_session:请求走了,把session字典中的值,序列化加密,放到cookie中

请求来了执行:open_session

def open_session(self, app, request) :
    s = self.get_signing_serializer(app)
    if s is None:
        return None
    # val 就是取出的三段:eyJhZ2UiOiIxOSIsIm5hbWUiOiJscXoifQ.Y5ac9g.vOomQFqFuaqXWqRQhvSNyc61UIk
    val = request.cookies.get('session')
    if not val:
        return self.session_class()
    max_age = int(app.permanent_session_lifetime.total_seconds())
    try:
        data = s.loads(val, max_age=max_age)
        return self.session_class(data)
    except BadSignature:
        return self.session_class()

请求走了执行:save_session

 def save_session(self, app, session, response):
        name = self.get_cookie_name(app)
        domain = self.get_cookie_domain(app)
        path = self.get_cookie_path(app)
        secure = self.get_cookie_secure(app)
        samesite = self.get_cookie_samesite(app)
        httponly = self.get_cookie_httponly(app)

        if not session:  # 如果视图函数放了,不为空 session['name']='curry'
            if session.modified: 
                response.delete_cookie(
                    name,
                    domain=domain,
                    path=path,
                    secure=secure,
                    samesite=samesite,
                    httponly=httponly,
                )

            return

  
        if session.accessed:
            response.vary.add("Cookie")

        if not self.should_set_cookie(app, session):
            return

        expires = self.get_expiration_time(app, session)
        # 序列化——>加密了
        val = self.get_signing_serializer(app).dumps(dict(session))  # type: ignore
        # 三段:
        response.set_cookie(
            name, # session
            val,  # 三段:
            expires=expires,
            httponly=httponly,
            domain=domain,
            path=path,
            secure=secure,
            samesite=samesite,
        )

总结:session的执行流程

请求来了

  • 执行open_session——>取出cookie,判断是否为空,如果不为空,把它反序列化,解密——>字典——>转到session对象中——>视图函数

请求走了

  • 会执行save_session——>把session转成字典——>序列化加密——>三段——>放到cookie中

三、闪现

flash:翻译过来叫闪现

作用:

    访问a页面,出了错,重定向到了b页面,要在b页面线上a页面的错误信息,在某个请求中放入值,另一个请求中取出,取出来后就没了

使用方式一:

设置值:flash('不好意思,没有权限看')可以用多次

取值:取出列表  get_flashed_messages()

使用方式二:分类设置和获取

设置值:
    flash('篮球运动员',category='curry')
    flash('666',category='c1')')
    可以用多次
取值:取出列表
    errors = get_flashed_messages(category_filter=['curry'])

四、补充异步

# 异步框架 FastAPi
async def index():
    print('sdfasd')
    a++
    await xxx  # io操作
async def goods():   
    pass
# 框架之前的web框架,开启进程,线程---》一条线程会运行多个协程函数----》协程函数中遇到io,读到await关键字,就会切换到别的协程函数


# 一旦使用了异步,以后所有的模块,都要是异步
	-pymysql :同步的
    -redis :同步
    -aiomysql:异步
    -aioredis:异步
    -在fastapi或sanic中,要操作mysql,redis要使用异步的框架,否则效率更低
    -django 3.x 以后页支持async 关键字
    -没有一个特别好异步的orm框架
    	-sqlalchemy在做
        -tortoise-orm
        https://tortoise-orm.readthedocs.io/en/latest/index.html
    
    
# aiomysql
import asyncio
import aiomysql

loop = asyncio.get_event_loop()

async def test_example():
    conn = await aiomysql.connect(host='127.0.0.1', port=3306,
                                       user='root', password='', db='mysql',
                                       loop=loop)

    cur = await conn.cursor()
    await cur.execute("SELECT Host,User FROM user")
    print(cur.description)
    r = await cur.fetchall()
    print(r)
    await cur.close()
    conn.close()

loop.run_until_complete(test_example())


# aioredis
import aioredis
import asyncio
class Redis:
    _redis = None
    async def get_redis_pool(self, *args, **kwargs):
        if not self._redis:
            self._redis = await aioredis.create_redis_pool(*args, **kwargs)
        return self._redis

    async def close(self):
        if self._redis:
            self._redis.close()
            await self._redis.wait_closed()


async def get_value(key):
    redis = Redis()
    r = await redis.get_redis_pool(('127.0.0.1', 6379), db=7, encoding='utf-8')
    value = await r.get(key)
    print(f'{key!r}: {value!r}')
    await redis.close()         

if __name__ == '__main__':
    asyncio.run(get_value('key'))  # need python3.7

五、请求扩展

  • 在请求进入视图函数之前,执行一些代码
  • 请求出了视图函数以后,执行一些代码
  • 类似于django的中间件完成的功能

7个装饰器(重点前两个)

1、before_request:在请求进视图函数之前执行

多个的话,会从上往下,依次执行, django:process_request
如果返回四件套之一,就直接返回了
在这里面,正常使用request对象

2、after_request:在请求从视图函数走之后执行

多个的话,会从下往上,依次执行, django:process_response一样
要有参数,和返回值,参数就是response对象,返回值也必须是resposne对象
session,request 照常使用
向响应头写东西?向cookie中写东西

3、before_first_request:项目启动后,第一次访问会执行,以后再也不执行了

  • 可以做一些初始化的操作

4、teardown_request:每一个请求之后绑定一个函数,即使遇到了异常,每个请求走,都会执行,记录错误日志

@app.teardown_request
def tear_down(e):
    print(e)  # 如果有异常,这是异常对象
    print('我执行了')

5、errorhandler路径不存在时404,服务器内部错误500

# @app.errorhandler(404)
# def error_404(arg):
#     print('404会执行我')
#     # return "404错误了"
#     return render_template('404.html')

@app.errorhandler(500)  # debug为False请情况下才能看到
def error_500(arg):
    print('500会执行我')
    return "服务器内部错误"

6、template_global 标签 ,在模板中用  {{sb(1,2)}}

@app.template_global()
def sb(a1, a2):
    return a1 + a2

7、template_filter过滤器  在模板中用  {{10|db(1,2)}}

@app.template_filter()
def db(a1, a2, a3):
    return a1 + a2 + a3

 六、蓝图

blueprint:对目录进行划分,因为之前所有代码都写在一个py文件中,后期肯定要分到多个文件中

 蓝图就是为了划分目录的

 使用步骤:

  1. 在不同的view的py文件中,定义蓝图
  2. 使用app对象,注册蓝图
  3. 使用蓝图,注册路由,注册请求扩展

 不用蓝图划分目录

 目录结构

  • flask_blueprint
    • static  # 静态文件存放位置
    • templates # 模板存放位置
      • user.html # 用户html页面
    • views    # 视图函数的py文件
      • __init__.py # 里面定义了Flask的app对象
      • goods.py    # 商品相关视图  
      • user.py    # 用户相关视图
    • app.py         #启动文件

蓝图小型项目

flask_blueprint_little  # 项目名

  •  src                # 项目代码所在路径
    • __init__.py   # app对象创建的地方
    • templates     # 模板
      • user.html
    • static       # 静态文件
    • views        # 视图函数存放位置
      • user.py  # 用户相关视图
      • order.py # 订单相关视图
  • manage.py  # 启动文件

大型项目

flask_blurprint_big   # 项目名字

  •  src   # 项目代码所在位置
    • __init__.py # src的init,falsk,app实例化
    • settings.py # 配置文件
    • admin       # 类似于django的admin app
      • __init__.py # 蓝图初始化
      • template   # 模板
        • backend.html  
      • static   # 静态文件
        • xx.jpg
      • views.py  # 视图层
      • models.py # models层,后期咱们表模型
    • api
      • __init__.py
      • template
      • static
      • models.py
      • views.py
    • manage.py  # 启动文件

标签:03,flask,app,request,session,cookie,print,self
From: https://www.cnblogs.com/zzjjpp/p/16977110.html

相关文章

  • flask(三)
    今日内容概要请求与响应session闪现异步请求扩展蓝图今日内容详细#wsgi协议:Web服务器网关接口(PythonWebServerGatewayInterface,缩写为WSGI)是为Python语......
  • Flask学生信息管理系统,前后端分离(附完整源码+数据库)
    文章目录​​一、演示​​​​二、Flask基础​​​​三、项目设计​​​​3.1数据库设计​​​​3.2页面设计​​​​3.3涉及技术​​​​3.4页面截图​​​​四、程序​......
  • 如何在笔记本上安装openEuler 22.03 LTS
    ✦1、准备工作✦  首先在openEuler官网下载ISO镜像,下载地址为https://repo.openeuler.org/openEuler-22.03-LTS/ISO/x86_64/,为了快速下载安装,选择3.4G大小的openEuler-2......
  • pkgship 2.1.0 移植指南 (openEuler 20.03 LTS SP1)
    简介pkgship是一款管理OS软件包依赖关系,提供依赖和被依赖关系完整图谱的查询工具,pkgship提供软件包依赖查询、生命周期管理、补丁查询等功能。选用版本2.1.0检查当前系统版......
  • Varnish 6.2.0 移植指南(openEuler 20.03 LTS SP1)
    介绍简要介绍Varnish是一款高性能且开源的反向代理服务器和HTTP加速器,与传统的缓存服务器相比,Varnish具有性能更高、速度更快、管理更加方便等诸多优点,很多大型的网站都开始......
  • Squid 4.8 移植指南(openEuler 20.03 LTS SP1)
    介绍简要介绍Squidcache(简称为Squid)是一个流行的代理服务器和Web缓存服务器,是一个开源软件(GNU通用公共许可证)。Squid有广泛的用途,从作为网页服务器的前置cache服务器缓存相......
  • Nginx 1.14.2 移植指南(openEuler 20.03 LTS SP1)
    介绍简要介绍Nginx是一款轻量级的Web服务器/反向代理服务器及电子邮件(IMAP/POP3)代理服务器,其特点是占有内存少,并发能力强,支持FastCGI、SSL、VirtualHost、URLRewrite、gzi......
  • Memcached 1.5.12 移植指南(openEuler 20.03 LTS SP1)
    Memcached1.5.12移植指南介绍简要介绍Memcached是LiveJournal旗下DangaInteractive公司以BradFitzpatric为首开发的一款高性能分布式内存对象缓存系统,通过缓存数据库查......
  • Lighttpd 1.4.53 移植指南(openEuler 20.03 LTS SP1)
    介绍简要介绍Lighttpd是开源Web服务器软件,其根本的目的是提供一个专门针对高性能网站,安全、快速、兼容性好并且灵活的WebServer环境。具有非常低的内存开销、CPU占用率低......
  • HAProxy 1.9.0 移植指南(openEuler 20.03 LTS SP1)
    介绍简要介绍HAProxy是一个使用C语言编写的自由及开放源代码软件,其提供高可用性、负载均衡,以及基于TCP和HTTP的应用程序代理,支持虚拟主机,它是免费、快速并且可靠的一种解决......