streamcount.py

def stream(q):
    def before_cursor_execute(conn, cursor, statement, parameters, context, executemany):
        cursor.scrollable = True
    with sql.rds_engine.engine.connect() as conn:
        streamconn = conn.execution_options(stream_results=True)
        sa.event.listen(streamconn, "before_cursor_execute", before_cursor_execute)
        results = streamconn.execute(q)
        print "rowcount", results.rowcount
        r = conn.execute("MOVE FORWARD ALL FROM {}".format(results.cursor.name))
        r = conn.execute("MOVE BACKWARD ALL FROM {}".format(results.cursor.name))
        print "CORRECT rowcount", r.rowcount