1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
.. _request_body:
Consuming the request body
==========================
Requests can come with a body, for example for a POST request the body
can include form encoded data from a webpage or JSON encoded data from
a client. The body is sent after the request line and headers for both
HTTP/1 and HTTP/2. This allows Quart to trigger the app's request
handling code before the full body has been received. Additionally the
requester can choose to stream the request body, especially if the
body is large as is often the case when sending files.
Quart follows Flask and provides methods to await the entire body
before continuing,
.. code-block:: python
@app.route('/', methods=['POST'])
async def index():
await request.get_data()
Advanced usage
--------------
You may wish to completely control how the request body is consumed,
most likely to consume the data as it is received. To do this quart
provides methods to iterate over the body,
.. code-block:: python
from async_timeout import timeout
@app.route('/', methods=['POST'])
async def index():
async with timeout(app.config['BODY_TIMEOUT']):
async for data in request.body:
...
.. note::
The above snippet uses `Async-Timeout
<https://github.com/aio-libs/async-timeout>`_ to ensure the body is
received within the timeout specified.
.. warning::
Whilst the other request methods and attributes for accessing the
body will timeout if the client takes to long send the
request. Usage of :attr:`~quart.wrappers.request.Request.body` will
not and it is up to you to wrap usage in a timeout.
.. warning::
Iterating over the body consumes the data, so any further usage of
the data is not possible unless it is saved during the iteration.
Testing
-------
To test that a route consumes the body iteratively you will need to use
the :meth:`~quart.testing.client.QuartClient.request` method,
.. code-block:: python
async def test_stream() -> None:
test_client = app.test_client()
async with test_client.request(...) as connection:
await connection.send(b"data")
await connection.send_complete()
response = await connection.as_response()
assert response ...
it also makes sense to check the code cleans up as you expect if the
client disconnects whilst the request body is being sent,
.. code-block:: python
async def test_stream_closed() -> None:
test_client = app.test_client()
async with test_client.request(...) as connection:
await connection.send(b"partial")
await connection.disconnect()
# Check cleanup markers....
|
