flask 异步编程 asyncio_flask asyncio

1. Flask 与异步编程

在编写Web应用程序时，有时需要调用可能需要一些时间的外部服务或执行耗时操作的函数。在传统的同步编程中，这将导致整个应用程序阻塞，直到该函数返回结果。为了提高应用程序的性能和响应能力，我们可以使用异步编程。
异步编程允许同时处理多个任务，而不会阻塞其他代码的执行。在 Python 中，我们可以使用 asyncio 模块来实现异步代码。asyncio 提供了一种基于协程的方法来编写异步代码，通过使用 async 和 await 关键字来标识异步函数。

2. 基础异步编程

2.1. 在 Flask 路由中调用异步函数

要在 Flask 路由函数中调用异步函数，我们需要将路由函数本身声明为异步函数，并使用await关键字调用异步函数。下面是一个示例：

from flask import Flask
import asyncio	# 引入异步函数库

app = Flask(__name__)

async def async_function():
    await asyncio.sleep(3)
    return "Hello, Flask and asyncio!\n"

@app.route("/")
async def index():	# 声明路由函数为异步函数
    result = await async_function()
    return result

if __name__ == "__main__":
    app.run(host="0.0.0.0", port=8000)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

运行结果：

user@ubuntu:~$ curl -i http://192.168.98.171:8000
HTTP/1.1 200 OK
Server: Werkzeug/2.2.2 Python/3.10.9
Date: Tue, 05 Dec 2023 01:21:16 GMT
Content-Type: text/html; charset=utf-8
Content-Length: 26
Connection: close

**Hello, Flask and asyncio!**
1
2
3
4
5
6
7
8
9

在这个例子中，我们定义了一个 async_function 函数，它模拟了一个需要3秒钟才能返回结果的异步操作。在 index 路由函数中，我们使用await 关键字调用了 async_function 函数，并将结果返回给客户端。当用户访问根路由时，会等待3秒钟才返回结果。

2.2. 在 Flask 路由中使用异步库

除了自己定义的异步函数外，我们还可以使用其他异步库和模块来处理异步任务。在使用这些库时，我们需要确保它们与 Flask 框架兼容，并正确使用异步函数。
下面是一个使用 aiohttp 库进行异步HTTP请求的示例：

from flask import Flask
import aiohttp
import asyncio

app = Flask(__name__)

async def fetch(session, url):
    async with session.get(url) as response:
        return await response.text()

async def async_request():
    async with aiohttp.ClientSession() as session:
        response = await fetch(session, 'https://example.com')
        return response

@app.route("/")
async def index():
    result = await async_request()
    return result

if __name__ == "__main__":
    app.run()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

在这个例子中，我们使用 aiohttp 库发送异步 HTTP 请求。我们定义了一个 fetch 函数来处理请求，并在 async_request 函数中使用它。在index 路由函数中，我们使用 await 关键字调用 async_request 函数，并将请求结果返回给客户端。

3. 异步编程进阶

3.1. 流式异步编程

未完善
不完全参考 asyncio：
https://yanbin.blog/how-flask-work-with-asyncio/

不完全参考 流式返回
https://deepinout.com/flask/flask-questions/173_flask_streaming_data_with_python_and_flask.html
https://geek-docs.com/flask/flask-questions/102_flask_how_to_return_value_from_async_method_in_python.html?action=all
https://zhuanlan.zhihu.com/p/645053138
https://www.cnblogs.com/ExMan/p/14298905.html

1