レビュー: 非同期処理の問題

1import asyncio
2import aiohttp
3 
4async def fetch_multiple_apis(urls):
5    """Fetch data from multiple APIs"""
6    results = await asyncio.gather(*[fetch_data(url) for url in urls])
7    return results
8 
9def fetch_data(url):
10    """Fetch data from a single API"""
11    return fetch_api(url)
12 
13async def fetch_api(url):
14    """Actual API call"""
15    with aiohttp.ClientSession() as session:
16        response = session.get(url)
17        data = response.json()
18        return data
19 
20async def process_results(results):
21    """Process API results"""
22    processed = []
23    for data in results:
24        result = process_data(data)
25        processed.append(result)
26    return processed
27 
28async def process_data(data):
29    """Process single data item"""
30    return {"processed": data}