非同期コルーチン開発スキル: 効率的なデータのキャプチャと分析の実現

import asyncio
import aiohttp
import asyncpg

async def fetch_article(url):
    async with aiohttp.ClientSession() as session:
        async with session.get(url) as response:
            if response.status == 200:
                data = await response.json()
                return data['title'], data['content']

async def save_article(title, content):
    conn = await asyncpg.connect('postgresql://user:password@localhost/db')
    await conn.execute('INSERT INTO articles (title, content) VALUES ($1, $2)', title, content)
    await conn.close()

async def process_article(url):
    title, content = await fetch_article(url)
    await save_article(title, content)

async def main():
    urls = ['https://example.com/article/1', 'https://example.com/article/2', 'https://example.com/article/3']
    tasks = [asyncio.create_task(process_article(url)) for url in urls]
    await asyncio.wait(tasks)

asyncio.run(main())