Falcon - Stream aiohttp response example

stream_aiohttp_response_falcon.py

# Courtesy of Vytautas Liuolia @vytas7 

import aiohttp
import falcon.asgi


class Proxy(object):
    UPSTREAM = 'https://falconframework.org'

    async def handle(self, req, resp):
        headers = dict(req.headers, Via='Falcon')
        for name in ('host', 'connection', 'referer'):
            headers.pop(name, None)

        async with aiohttp.ClientSession() as session:
            async with session.get(
                    self.UPSTREAM + req.path, headers=headers) as response:
                resp.data = await response.read()
                resp.content_type = response.headers.get(
                    'Content-Type', falcon.MEDIA_HTML)
                resp.status = response.status


app = falcon.asgi.App()
app.add_sink(Proxy().handle)

TODO: Explore ways to add native support to the framework.