import aiohttp
import aiofiles
import asyncio
import os
import csv

async def main():
    tasks = []
    headers = {
        "user-agent": "Mozilla/5.0 (compatible; Googlebot/2.1; +http://www.google.com/bot.html)"}
    async with aiohttp.ClientSession(headers=headers) as session:
        with open('SOT.csv', newline='') as csvfile:
            spamreader = csv.reader(csvfile, delimiter=',', quotechar='"')
            for row in spamreader:
                name=row[1].replace("'","").replace(" ","_").replace('"','').replace(",","").replace("!","").lower()
                img=row[40]
                img=img.replace('<img>','').replace('</img>','')
                print(name,img)
                if img!="image":
                    async with session.get(img) as resp:
                        async with aiofiles.open("../"+name+"_sot.jpg", mode='wb') as f:
                            await f.write(await resp.read())
                            await f.close()

try:
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())
except Exception as e:
    print(e)