这篇文章主要介绍了Flask如何实现异步执行任务的相关知识，内容详细易懂，操作简单快捷，具有一定借鉴价值，相信大家阅读完这篇Flask如何实现异步执行任务文章都会有所收获，下面我们一起来看看吧。Flask 是 Python 中有名的轻量级同步 web 框架，在一些开发中，可能会遇到需要长时间处理的任务，此时就需要使用异步的方式来实现，让长时间任务在后台运行，先将本次请求的响应状态返回给前端，不让前端界面「卡顿」，当异步任务处理好后，如果需要返回状态，再将状态返回。当要执行耗时任务时，直接开启一个新的线程来执行任务，这种方式最为简单快速。通过 ThreadPoolExecutor 来实现当要执行一些比较简单的耗时任务时就可以使用这种方式，如发邮件、发短信验证码等。但这种方式有个问题，就是前端无法得知任务执行状态。如果想要前端知道，就需要设计一些逻辑，比如将任务执行状态存储到 redis 中，通过唯一的任务 id 进行标识，然后再写一个接口，通过任务 id 去获取任务的状态，然后让前端定时去请求该接口，从而获得任务状态信息。全部自己实现就显得有些麻烦了，而 Celery 刚好实现了这样的逻辑，来使用一下。为了满足前端可以获得任务状态的需求，可以使用 Celery。Celery 是实时任务处理与调度的分布式任务队列，它常用于 web 异步任务、定时任务等，后面单独写一篇文章描述 Celery 的架构，这里不深入讨论。现在我想让前端可以通过一个进度条来判断后端任务的执行情况。使用 Celery 就很容易实现，首先通过 pip 安装 Celery 与 redis，之所以要安装 redis，是因为让 Celery 选择 redis 作为「消息代理 / 消息中间件」。在 Flask 中使用 Celery 其实很简单，这里先简单的过一下 Flask 中使用 Celery 的整体流程，然后再去实现具体的项目1.在 Flask 中初始化 Celery上述代码中，通过 Celery 类初始化 celery 对象，传入的应用名称与消息代理的连接 URL。2.通过 celery.task 装饰器装饰耗时任务对应的函数3.Flask 中定义接口通过异步的方式执行耗时任务delay () 与 apply_async () 会返回一个任务对象，该对象可以获取任务的状态与各种相关信息。
通过这 3 步就可以使用 Celery 了。接着就具体来实现「让前端可以通过一个进度条来判断后端任务的执行情况」的需求。上述代码中，celery.task () 装饰器使用了 bind=True 参数，这个参数会让 Celery 将 Celery 本身传入，可以用于记录与更新任务状态。然后就是一个 for 迭代，迭代的逻辑没什么意义，就是随机从 list 中抽取一些词汇来模拟一些逻辑的运行，为了表示这是耗时逻辑，通过 time.sleep (1) 休眠一秒。每次获取一次词汇，就通过 self.update_state () 更新 Celery 任务的状态，Celery 包含一些内置状态，如 SUCCESS、STARTED 等等，这里使用了自定义状态「PROGRESS」，除了状态外，还将本次循环的一些信息通过 meta 参数 (元数据) 以字典的形式存储起来。有了这些数据，前端就可以显示进度条了。定义好耗时方法后，再定义一个 Flask 接口方法来调用该耗时方法简单而言，前端通过 POST 请求到 /longtask，让后端开始去执行耗时任务。返回的状态码为 202，202 通常表示一个请求正在进行中，然后还在返回数据包的包头 (Header) 中添加了 Location 头信息，前端可以通过读取数据包中 Header 中的 Location 的信息来获取任务 id 对应的完整 url。前端有了任务 id 对应的 url 后，还需要提供一个接口给前端，让前端可以通过任务 id 去获取当前时刻任务的具体状态。为了可以获得任务对象中的信息，使用任务 id 初始化 AsyncResult 类，获得任务对象，然后就可以从任务对象中获得当前任务的信息。该方法会返回一个 JSON，其中包含了任务状态以及 meta 中指定的信息，前端可以利用这些信息构建一个进度条。如果任务在 PENDING 状态，表示该任务还没有开始，在这种状态下，任务中是没有什么信息的，这里人为的返回一些数据。如果任务执行失败，就返回 task.info 中包含的异常信息，此外就是正常执行了，正常执行可以通 task.info 获得任务中具体的信息。这样，后端的逻辑就处理完成了，接着就来实现前端的逻辑，要实现图形进度条，可以直接使用 nano免费云主机域名bar.js，简单两句话就可以实现一个进度条，其官网例子如下：有了 nanobar.js 就非常简单了。先定义一个简单的 HTML 界面通过 JavaScript 实现对后台的请求可以通过注释阅读代码整体逻辑。至此，需求实现完了，运行一下。首先运行 Redis然后运行 celery最后运行 Flask 项目关于“Flask如何实现异步执行任务”这篇文章的内容就介绍到这里，感谢各位的阅读！相信大家对“Flask如何实现异步执行任务”知识都有一定的了解，大家如果还想学习更多知识，欢迎关注百云主机行业资讯频道。
本文小编为大家详细介绍“html文档结构是怎样的”，内容详细，步骤清晰，细节处理妥当，希望这篇“html文档结构是怎样的”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。Html的文档结构如下图所示，非常容易理解。在这张图中，展示的是h…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
