Python上級

上級 Pythonで学ぶ非同期処理｜ケーススタディ編

 

導入

非同期処理は、特にI/Oバウンドなタスクが多い現場において、効率的なリソース管理を実現するための重要な技術です。ある架空のプロジェクトを通じて、実際の業務で遭遇する可能性のあるシナリオを考え、非同期処理の実装方法とその利点を探ります。

教科書レベルの解説（非同期処理）

重要な概念の整理

非同期処理とは、プログラムが他の処理を待たずに次の処理を進めることを指します。これにより、特にネットワーク通信やファイルI/Oなどの遅延が発生しやすい操作において、全体の処理時間を短縮することが可能です。Pythonでは、async/await構文を用いることで、非同期処理を簡潔に記述できます。

コード例（Python）


import asyncio
import aiohttp

async def fetch_data(url):
    async with aiohttp.ClientSession() as session:
        async with session.get(url) as response:
            return await response.text()

async def main(urls):
    tasks = [fetch_data(url) for url in urls]
    return await asyncio.gather(*tasks)

urls = ['https://example.com', 'https://example.org', 'https://example.net']
data = asyncio.run(main(urls))
print(data)

コードの行ごとの解説

  1. import asyncio: 非同期処理を行うためのasyncioモジュールをインポートします。
  2. import aiohttp: 非同期HTTPリクエストを行うためのaiohttpライブラリをインポートします。
  3. async def fetch_data(url): 指定されたURLからデータを非同期に取得する関数を定義します。
  4. async with aiohttp.ClientSession() as session: 非同期セッションを作成し、HTTPリクエストを行います。
  5. async with session.get(url): URLにGETリクエストを送信します。
  6. return await response.text(): レスポンスのテキストを非同期に取得し、返します。
  7. async def main(urls): 複数のURLからデータを非同期に取得するメイン関数を定義します。
  8. tasks = [fetch_data(url) for url in urls]: 各URLに対してfetch_data関数を呼び出すタスクのリストを作成します。
  9. return await asyncio.gather(*tasks): すべてのタスクを非同期に実行し、結果を集約して返します。
  10. data = asyncio.run(main(urls)): main関数を実行し、データを取得します。
  11. print(data): 取得したデータを出力します。

ケーススタディ編

ある企業が、複数の外部APIからデータを収集し、分析するシステムを構築する必要があるとします。このシステムでは、各APIからの応答を待つ間に他の処理を行うことが求められます。非同期処理を用いることで、各APIへのリクエストが完了するのを待つことなく、効率的にデータを収集できます。

ただし、実装においては、APIの応答時間やエラーハンドリングの考慮が必要です。例えば、特定のAPIが遅延した場合、全体の処理が遅くなる可能性があります。これを回避するために、タイムアウトを設定することが推奨されます。以下は、タイムアウトを追加した改良版のコード例です。


async def fetch_data_with_timeout(url, timeout=5):
    async with aiohttp.ClientSession() as session:
        try:
            async with session.get(url, timeout=timeout) as response:
                return await response.text()
        except asyncio.TimeoutError:
            return f"Request to {url} timed out."

このように、非同期処理を適切に実装することで、よりスムーズで信頼性の高いシステムを構築することが可能です。

まとめ

  • 非同期処理はI/Oバウンドなタスクにおいて特に効果的です。
  • エラーハンドリングやタイムアウトの設定を行うことで、実務におけるリスクを軽減できます。
  • 他のプログラミング言語でも非同期処理の概念は応用可能であり、設計思想を共有できます。
RELATED POST