aiohttpリクエストとレスポンスの関連付け

Question

非常に単純に、aiohttpの非同期HTTPリクエストからの応答を二重キーなどの識別子に関連付けて、どのリクエストがどのリクエストに対応しているかを知ることができます。

たとえば、次の関数は、dict値1,2および3が付いたURIを呼び出します。各結果に関連付けられたキーを返すように変更するにはどうすればよいですか？私は、要求があるを追跡できるようにする必要があります... asyncio

import asyncio 
import aiohttp 

items = {'a': '1', 'b': '2', 'c': '3'} 

def async_requests(items): 
    async def fetch(item): 
     url = 'http://jsonplaceholder.typicode.com/posts/' 
     async with aiohttp.ClientSession() as session: 
      async with session.get(url + item) as response: 
       return await response.json() 

    async def run(loop): 
     tasks = [] 
     for k, v in items.items(): 
      task = asyncio.ensure_future(fetch(v)) 
      tasks.append(task) 
     responses = await asyncio.gather(*tasks) 
     print(responses) 

    loop = asyncio.get_event_loop() 
    future = asyncio.ensure_future(run(loop)) 
    loop.run_until_complete(future) 

async_requests(items) 

出力（省略）に精通している誰かのための疑いもなくは些細：（例）

[{'id': 2, ...}, {'id': 3, ...}, {'id': 1...}] 

所望の出力：

{'b': {'id': 2, ...}, 'c': {'id': 3, ...}, 'a': {'id': 1, ...}} 

Answer 1

fetch()にキーを渡して、対応する応答で返信します。

#!/usr/bin/env python 
import asyncio 
import aiohttp # $ pip install aiohttp 

async def fetch(session, key, item, base_url='http://example.com/posts/'): 
    async with session.get(base_url + item) as response: 
     return key, await response.json() 

async def main(): 
    d = {'a': '1', 'b': '2', 'c': '3'} 
    with aiohttp.ClientSession() as session: 
     ####tasks = map(functools.partial(fetch, session), *zip(*d.items())) 
     tasks = [fetch(session, *item) for item in d.items()] 
     responses = await asyncio.gather(*tasks) 
    print(dict(responses)) 

asyncio.get_event_loop().run_until_complete(main())