progress-bar - tqdmを使用したasyncio aiohttpプログレスバー

Question

tqdmプログレスバーを統合してaiohttp、Python 3.5 で生成された POST リクエストを監視しようとしています。作業中の進行状況バーがありますが、を使用して結果を収集できないようですas_completed()。ポインタはありがたく受け取った。

私が見つけた例では、Python 3.5 のasync def定義と互換性のない次のパターンを使用することを提案しています。

for f in tqdm.tqdm(asyncio.as_completed(tasks), total=len(coros)):
    yield from f

プログレスバーなしで動作する（編集されていますが）非同期コード：

def async_classify(records):

    async def fetch(session, name, sequence):
        url = 'https://app.example.com/api/v0/search'
        payload = {'sequence': str(sequence)}
        async with session.post(url, data=payload) as response:
            return name, await response.json()

    async def loop():
        auth = aiohttp.BasicAuth(api_key)
        conn = aiohttp.TCPConnector(limit=100)
        with aiohttp.ClientSession(auth=auth, connector=conn) as session:
            tasks = [fetch(session, record.id, record.seq) for record in records]
            responses = await asyncio.gather(*tasks)    
        return OrderedDict(responses)

これは私の失敗した変更の試みloop()です:

async def loop():
    auth = aiohttp.BasicAuth(api_key)
    conn = aiohttp.TCPConnector(limit=100)
    with aiohttp.ClientSession(auth=auth, connector=conn) as session:
        tasks = [fetch(session, record.id, record.seq) for record in records]
        for f in tqdm.tqdm(asyncio.as_completed(tasks), total=len(tasks)):
            await f
        responses = await asyncio.gather(f)
        print(responses)