Aiohttp不執行任何請求

Question

首先繼承人的代碼：

import random 
import asyncio 
from aiohttp import ClientSession 
import csv 

headers =[] 
def extractsites(file): 
    sites = [] 
    readfile = open(file, "r") 
    reader = csv.reader(readfile, delimiter=",") 
    raw = list(reader) 
    for a in raw: 
     sites.append((a[1])) 
    return sites 

async def bound_fetch(sem, url): 
    async with sem: 
     print("doing request for "+ url) 
     async with ClientSession() as session: 
      async with session.get(url) as response: 
       responseheader = await response.headers 
       print(headers) 


async def run(): 
    urls = extractsites("cisco-umbrella.csv") 
    tasks = [] 
    sem = asyncio.Semaphore(100) 
    for i in urls: 
     task = asyncio.ensure_future(bound_fetch(sem, "http://"+i)) 
     tasks.append(task) 
    headers = await asyncio.wait(*tasks) 
    print(headers) 


def main(): 
    loop = asyncio.get_event_loop() 
    future = asyncio.ensure_future(run()) 
    loop.run_until_complete(future) 

if __name__ == '__main__': 
    main() 

按我的最後一個問題，我下面的這篇博客文章： https://pawelmhm.github.io/asyncio/python/aiohttp/2016/04/22/asyncio-aiohttp.html

我試着去適應我的代碼儘可能接近可能的示例實現，但這個代碼仍然沒有發出任何請求，並按照我的意願在bound_headers中打印標題。

有人可以發現這個代碼有什麼問題嗎？

Answer 1

response.headers是一個普通的屬性，沒有必要在另一方面通話

asyncio.wait之前放的await接受期貨的列表，並返回(done, pending)對。 看起來你應該更換await wait()調用與await asyncio.gather(*tasks)（gather doc）