A sample python script with a wrapper for client sessions

pythonSampleClientSessionClass.py

#!/usr/bin/env python3
import asyncio

import aiohttp
from aiohttp import ClientSession

# use atexit module
import atexit

class SessionController:
    def __init__(self):
        self.loop = asyncio.get_event_loop()
        self.mySession = ClientSession(loop=self.loop)
        atexit.register(lambda: asyncio.get_event_loop().run_until_complete(self.endSession()))
    def __enter__(self):
        return self
    async def __exit__(self, exc_type, exc_value, traceback):
        await self.endSession()
    async def endSession(self):
        await self.mySession.close()

    def batch(self,iterable, n=1):
        l = len(iterable)
        for ndx in range(0, l, n):
            yield iterable[ndx:min(ndx + n, l)]

async def testCall(val,session):
    print("start"+str(val))
    t1 = await session.request("GET",'http://python.org/'+str(val))
    c = await t1.text()
    print(c[4:12])
    print(val)

def batch(iterable, n=1):
    l = len(iterable)
    for ndx in range(0, l, n):
        yield iterable[ndx:min(ndx + n, l)]
        
async def getTest():
    mySessionController = SessionController()
    mySession = mySessionController.mySession
    for someBatch in batch(range(1,20),10):
        tasks = []
        for x in someBatch:
            task = asyncio.create_task(testCall(x,mySession))
            tasks.append(task)
        await asyncio.wait(tasks)
    await mySession.close()


loop = asyncio.get_event_loop()
loop.run_until_complete(getTest())