Python + Flask 执行异步任务

在使用Flask开发python的web应用时，可能会遇到需要较长时间处理的任务，此时就需要使用异步的方式来实现，让长时间任务在后台运行，先将本次请求的响应状态返回给前端，不然前端界面"卡顿"，当异步任务处理好后，如果需要返回状态，再将状态返回。

下面介绍两种常用的方式：

（1）使用线程的方式

当要执行耗时任务时，直接开启一个新的线程来执行任务，这种方式最为简单快速。

通过ThreadPoolExecutor来实现

asyn_request_demo.py

# -*- coding: UTF-8 -*-
"""
# rs
"""
from logzero import logger
import time
from flask import Flask
from flask_restful import Api
from flask import jsonify
from flask import make_response
from concurrent.futures import ThreadPoolExecutorexecutor = ThreadPoolExecutor()
# executor = ThreadPoolExecutor(10) 里面的数字是线程池所能同时进行的最大数量 app = Flask(__name__)
api = Api(app)def run(name, age):"""# 异步任务"""time.sleep(3)logger.info("name: %s, age: %s." % (name, age))logger.info("耗时任务执行结束")@app.route('/test')
def test():# 传递多个参数args = ["rongsong", "28"]# 交给线程去处理耗时任务, 异步执行executor.submit(lambda p: run(*p), args)# 直接返回结果result = {"code": "200","message": "success","data": "green"}return make_response(jsonify(result))if __name__ == "__main__":# 启动一个HTTP服务app.run(host="0.0.0.0", port=8800, debug=True)

使用pip3安装相应的库（不再赘述）。
使用python3 asyn_request_demo.py运行启动即可（启动端口8800，可修改）。
然后访问http://{执行机器所在IP}:8800/test观察。
预期可以看到：接口直接返回result结果（同步），后台日志等待5s左右打印日志"耗时任务执行结束"（异步）。

当要执行一些比较简单的耗时任务时可以使用这种方式，如发邮件、发送短信验证码等。

当这种方式有个很明显的问题，就是我们无法得到任务的执行状态。

如果想要随时得到任务的执行状态，就需要设计一些逻辑，比如奖任务执行状态存储到Redis中，通过唯一的任务id进行标识，然后再写一个接口通过任务id去获取任务的状态，然后让前端定时的去请求该接口，从而获得任务状态信息。

是不是有点复杂，如果让我们自己实现的话，哈哈哈，别慌，Celery框架刚好实现了这样的逻辑，比较成熟，一般我们遇到问题时都可以先看看有没有现成的框架和方法，毕竟站在巨人的肩膀上我们可以看的更远。

（2）使用Celery的方式

Celery是定时任务处理和调度的分布式任务队列，常用于web异步任务、定时任务等。

Python + Flask 执行异步任务相关推荐

基于Python Flask框架+jquery Ajax技术实现的增删改查（CRUD）+Ajax的异步文件上传
运行界面(话不多说先上图) 运行之后的index界面,有登陆.注册功能登陆界面,输入数据库中用户名.密码不为空且密码是加密的数据,进入main界面注册界面,用的bootstrop的弹窗,用户名和密 ...
Python+Flask
Web 项目学习笔记(持续更新) 开发Web项目的学习笔记-Python+Flask 表单与文本联动补充 input 作为单选按钮类型使用Python编码和解码Json对象 JQuery快速上手 ...
『Python学习笔记』Python中的异步Web框架之fastAPI介绍RestAPI
Python中的异步Web框架之fastAPI介绍&RestAPI 文章目录一. fastAPI简要介绍 1.1. 安装 1.2. 创建 1.3. get方法 1.4. post方法 1.5 ...
#3使用html+css+js制作网页番外篇使用python flask 框架 (I)
#3使用html+css+js制作网页番外篇使用python flask 框架(I 第一部) 0. 本系列教程 1. 准备 a.python b. flask c. flask 环境安装 d. f ...
fastapi python 并发_FastAPI 异步代码、并发和并行
作者:麦克煎蛋出处:https://www.cnblogs.com/mazhiyong/ 转载请保留这段声明,谢谢! 我们这里探讨下关于异步代码.并行和并发的一些概念. 一.初探 1.如果我们使 ...
python flask高级编程之restful_('Python Flask高级编程之RESTFul API前后端分离精讲',),全套视频教程学习资料通过百度云网盘下载...
资源详情 r n t某课网好评度100%的Python Flask高级编程之RESTFul API前后端分离精讲 r n t t t第1章随便聊聊 r n t t t聊聊Flask与Django,聊 ...
python协程详解_对Python协程之异步同步的区别详解
一下代码通过协程.多线程.多进程的方式,运行代码展示异步与同步的区别. import gevent import threading import multiprocessing # 这里展示同步和异 ...
python Flask框架如何请求及返回数据——flask详细教程
python Flask框架如何请求及返回数据--flask详细教程文章目录: 1 Flask介绍 1.1 Flask简单介绍 1.2 Flask相关资料信息 2 Flask快速入门 2.1 Fla ...
python processpoolexector 释放内存_一起看看python 中日志异步发送到远程服务器
在python中使用日志最常用的方式就是在控制台和文件中输出日志了,logging模块也很好的提供的相应的类,使用起来也非常方便,但是有时我们可能会有一些需求,如还需要将日志发送到远端,或者直接写入数 ...

Python + Flask 执行异步任务

Python + Flask 执行异步任务相关推荐

最新文章

热门文章