Flask asyncio 异步处理请求

来自：

Making Flask async and Quart sync (pgjones.dev)

示例：

from flask import Flask, jsonify, has_request_context, copy_current_request_context, request
from functools import wraps
from concurrent.futures import Future, ThreadPoolExecutor
import asynciodef run_async(func):@wraps(func)def _wrapper(*args, **kwargs):call_result = Future()def _run():loop = asyncio.new_event_loop()try:result = loop.run_until_complete(func(*args, **kwargs))except Exception as error:call_result.set_exception(error)else:call_result.set_result(result)finally:loop.close()loop_executor = ThreadPoolExecutor(max_workers=1)if has_request_context():_run = copy_current_request_context(_run)loop_future = loop_executor.submit(_run)loop_future.result()return call_result.result()return _wrapper@app.route("/process/report/success/", methods=["POST"])
@run_async
async def report_result_success():account = request.jsonprint(request.json)debug('>> 注册成功: ' + str(account))write_csv(account, '成功.csv')return Result.ok()

水话：

像Flask这样的Web框架是异步编程技术的完美用例，因为它们的目的是处理独立的无状态请求。此外，Web框架通常由IO而不是CPU工作主导，这使得它们成为异步事件循环的明显用例。

因此，Flask 通常与线程或事件循环一起使用。具体来说，非异步等待事件循环实现、eventlet、gevent 和 meinheld。异步解决方案之间的这种选择对 Flask 代码的影响非常小。

Flask自成立以来一直处于同步状态，并且大量公司以这种方式成功地在生产中运行它。然而，Python已经在标准库中发展并正式化了一个基于异步等待的事件循环，即asyncio，社区又增加了两个Curio和Trio。这些基于异步等待的事件循环需要更改代码才能与事件循环交互

Flask asyncio 异步处理请求相关推荐

python asyncio tcp转发_aiohttp + asyncio 异步网络请求基本操作
作者:matrix 被围观: 1,949 次发布时间:2019-11-26 无评论 »
python asyncio 异步 I/O - 实现并发http请求(asyncio + aiohttp)
前言如果需要并发 http 请求怎么办呢?requests库是同步阻塞的,必须等到结果才会发第二个请求,这里需使用http请求异步库 aiohttp. 环境准备 aiohttp 用于 asyncio ...
python flask源码解析_浅谈flask源码之请求过程
Flask Flask是什么? Flask是一个使用 Python 编写的轻量级 Web 应用框架, 让我们可以使用Python语言快速搭建Web服务, Flask也被称为 "microfr ...
python asyncio 异步编程-协程 2
asyncio 异步编程官方文档: 中文版:https://docs.python.org/zh-cn/3.8/library/asyncio.html 英文本:https://docs.pytho ...
Python3标准库：asyncio异步I/O、事件循环和并发工具
1. asyncio异步I/O.事件循环和并发工具 asyncio模块提供了使用协程构建并发应用的工具.threading模块通过应用线程实现并发,multiprocessing使用系统进程实现并发, ...
iOS 依次执行异步网络请求的一种实现
1.首先先介绍一个概念dispatch_semaphore dispatch_semaphore信号量为基于计数器的一种多线程同步机制.用于解决在多个线程访问共有资源时候,会因为多线程的特性而引发数据 ...
iOS网络开发中的同步、异步和请求队列
在iOS网络编程中,我们经常会遇到线程的同步和异步问题,同时为了对异步请求更加精准丰富的控制,我们还常常在iOS中使用请求队列,下面就来谈谈iOS开发中同步.异步以及请求队列的使用方法. 1. 同步意 ...
【OkHttp】OkHttp 源码分析 ( 同步 / 异步 Request 请求执行原理分析 )
OkHttp 系列文章目录 [OkHttp]OkHttp 简介 ( OkHttp 框架特性 | Http 版本简介 ) [OkHttp]Android 项目导入 OkHttp ( 配置依赖 | 配置 ...
【OkHttp】OkHttp Get 和 Post 请求 ( 同步 Get 请求 | 异步 Get 请求 | 同步 Post 请求 | 异步 Post 请求 )
OkHttp 系列文章目录 [OkHttp]OkHttp 简介 ( OkHttp 框架特性 | Http 版本简介 ) [OkHttp]Android 项目导入 OkHttp ( 配置依赖 | 配置 ...

Flask asyncio 异步处理请求

Flask asyncio 异步处理请求相关推荐

最新文章

热门文章