How to use Python Flask to implement a RESTful api that can handle put request by chunk?

Question

With Python Flask, it's not so difficult to handle put request and get the content in request.data. However, it is triggered when the whole data transmission completes and they're all in the buffer. What if I want the web server to be just a pipe and handle the incoming stream chunk by chunk, not assembling them all?

Something like how Nodejs does:

.on('data', function (chunk)
{
    //Process the chunk
});

Answer 1

You are looking for request.stream which gives you access to the underlying wsgi.input stream to read from:

CHUNK_SIZE = calculate_chunk_size(request)  # Your magic here
while check_some_condition(request):
    chunk = request.stream.read(CHUNK_SIZE)
    # Process chunk