aiohttp stream response example

aiopoc.py

from aiohttp import web


async def handle(request):
    response = web.StreamResponse(
        status=200,
        reason='OK',
        headers={'Content-Type': 'text/plain'},
    )
    await response.prepare(request)

    with open('aiopocdata.txt', 'r') as file:
        for line in file.readlines():
            await response.write(line.encode('utf-8'))

    await response.write_eof()
    return response


app = web.Application()
app.add_routes([
    web.get('/', handle)
])


web.run_app(app)