python stream server exemple

client_async.py

import asyncio
import httpx



async def async_client():
    async with httpx.AsyncClient() as client:
        async with client.stream('GET', 'http://127.0.0.1:5000/large.csv') as response:
            async for chunk in response.aiter_text():
                print(chunk)
                
                
 
loop = asyncio.get_event_loop()
a = loop.run_until_complete(async_client())

client_sync.py

import requests

r = requests.get('http://127.0.0.1:5000/large.csv', stream=True)
if r.encoding is None:
    r.encoding = 'utf-8'

for line in r.iter_lines(decode_unicode=True):
    if line:
        print(line)

server.py

from flask import Flask
from flask.wrappers import Response
import time

app = Flask(__name__)

def iter_all_rows(): # generate fake wait and fake list of data
    for i in range(100):
        yield [str(i),str(i*i), str(i+i)]
        time.sleep(1)

@app.route('/large.csv')
def generate_large_csv():
    def generate():
        for row in iter_all_rows():
            yield f"{','.join(row)}\n"
    return app.response_class(generate())