如何访问收集未来完成结果的内部数据

Question

一直试图弄清楚如何返回数据。如果我打印X的样本：

<_GatheringFuture finished result=[[{'ip': '173.245.203.70'}], [{'ip': '196.52.2.82'}], [{'ip': '69.161.4.1'}], [{'ip':'73.180.140.205'}], [{'ip': '96.242.181.128'}], [{'ip': '108.208.74.183'}], ...]>

我尝试了x [0]，x.Result，x.Results等...但只是遇到错误。有人知道如何在将来访问数据结果吗？感谢您的时间！这是下面的完整代码：

import asyncio
from bs4 import BeautifulSoup
from aiohttp import ClientSession
HEADERS = {'user-agent': 'Mozilla/5.0 (Windows NT 6.3; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36'}
proxy = 'xxx.xxx.xxx.xxx:xxxxx'
async def fetch(url, session):
 while True:
  x = []
  try:
   async with session.get(url, headers=HEADERS, proxy="http://{}".format(proxy), timeout=9) as r:
    print (r.status)
    if r.status == 200:
     data = await r.read()
     soup = BeautifulSoup(data, 'html.parser')
     for ip in soup.select('tr +  tr td font'):
      array.append({'ip' : ip.get_text()})
     break
  except:
   pass
 return x
async def bound_fetch(sem, url, session):
 async with sem:
  return await fetch(url, session)
async def run(num):
 tasks = []
 sem = asyncio.Semaphore(300)
 async with ClientSession() as session:
  for i in range(0,num):
   task = asyncio.ensure_future(bound_fetch(sem, 'http://ip4.me', session))
   tasks.append(task)
  responses = asyncio.gather(*tasks)
  await responses
  return responses
if __name__ == '__main__':
 loop = asyncio.get_event_loop()
 future = asyncio.ensure_future(run(10))
 x = loop.run_until_complete(future)
 loop.close()
 print (x)

Answer 1

在这里 responses您返回是从asyncio.gather获得的未来：

responses = asyncio.gather(*tasks)
await responses
return responses

您想要的是这个未来的结果。这样更改您的代码：

responses = await asyncio.gather(*tasks)
return responses