Stream SQLAlchemy result as CSV response in Django

utils.py

import csv
from sqlalchemy.engine.result import ResultProxy

class _Echo:
    def write(self, value):
        return value


def stream_csv(res: ResultProxy):
    w = _Echo()
    writer = csv.writer(w)
    yield writer.writerow(res.keys())
    for row in res:
        yield writer.writerow(row)

        

views.py

from django.http.response import StreamingHttpResponse
from .utils import stream_csv

class StreamCSVView(generic.View):

    def get(self, request, pk):
        sql = """select count(*) from table"""
        res = connection_or_engine.execute(text(sql))
        return StreamingHttpResponse(stream_csv(res), content_type='text/csv')