サイトアイコン 【TechGrowUp】

Python開発入門47 aiohttp入門

Daichi Mizuno

はじめに

PythonでWeb開発を行う際、非同期I/Oの利点を活かすことで、より効率的でスケーラブルなアプリケーションを構築することができます。aiohttpは、HTTPクライアントとサーバーの非同期処理を簡単に実現するためのライブラリで、高いパフォーマンスと柔軟性を兼ね備えています。

この記事では、aiohttpの基本的な使い方やアプリケーションの実装例を初心者向けに解説します。

aiohttpとは

aiohttpの概要

aiohttpは、Pythonの**非同期I/O（asyncio）**を利用したHTTPクライアントとサーバーのためのライブラリです。非同期タスクを効率的に処理できるため、以下のような用途に適しています：

aiohttpの主な特徴

  1. 非同期I/O対応
    asyncioを活用し、大量のリクエストを効率的に処理します。
  2. HTTPクライアントとサーバーの両方をサポート
    リクエスト送信からWebサーバー構築まで幅広く対応可能。
  3. 拡張性の高いアーキテクチャ
    ミドルウェアやカスタムルートなど、柔軟な設計が可能です。

aiohttpのインストールとセットアップ

aiohttpのインストール

以下のコマンドを使ってaiohttpをインストールします：

pip install aiohttp

aiohttpの基本セットアップ

インストール後、以下のコードを実行して正しくインストールされているか確認します：

import aiohttp
print(aiohttp.__version__)

aiohttpクライアントの基本操作

aiohttpクライアントを使うと、非同期でHTTPリクエストを簡単に送信できます。

HTTP GETリクエスト

以下は、GETリクエストの例です。

import aiohttp
import asyncio

async def fetch_url():
    async with aiohttp.ClientSession() as session:
        async with session.get("https://api.github.com") as response:
            print(await response.text())

asyncio.run(fetch_url())

説明：

HTTP POSTリクエスト

以下は、POSTリクエストを送信する例です。

async def post_data():
    async with aiohttp.ClientSession() as session:
        payload = {"key": "value"}
        async with session.post("https://httpbin.org/post", json=payload) as response:
            print(await response.json())

asyncio.run(post_data())

説明：

aiohttpサーバーの基本構造

aiohttpを使えば、シンプルなWebサーバーも構築可能です。

基本的なサーバー

以下は、aiohttpサーバーの基本的な例です。

from aiohttp import web

async def handle(request):
    return web.Response(text="Hello, aiohttp!")

app = web.Application()
app.router.add_get("/", handle)

web.run_app(app)

説明：

  1. web.Application: aiohttpのアプリケーションオブジェクト。
  2. add_get: ルート/へのGETリクエストを処理するハンドラーを追加。
  3. web.Response: レスポンスを返す。

パラメータの取得

URLパラメータやクエリ文字列の取得も簡単です。

async def handle(request):
    name = request.query.get("name", "デフォルト名")
    return web.Response(text=f"こんにちは、{name}さん！")

app.router.add_get("/", handle)

アクセス例：

http://localhost:8080/?name=太郎

JSONレスポンス

JSONデータを返すAPIサーバーも簡単に構築できます。

async def handle(request):
    data = {"message": "Hello, JSON!"}
    return web.json_response(data)

app.router.add_get("/json", handle)

aiohttpの応用例

非同期タスクの実行

非同期タスクを同時に実行することで、効率的な処理が可能です。

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

async def main():
    urls = ["https://example.com", "https://python.org"]
    tasks = [fetch_url(url) for url in urls]
    results = await asyncio.gather(*tasks)
    for result in results:
        print(result)

asyncio.run(main())

ミドルウェアの利用

aiohttpでは、ミドルウェアを使ってリクエストやレスポンスを加工できます。

@web.middleware
async def custom_middleware(request, handler):
    print("リクエストを受信")
    response = await handler(request)
    response.headers["X-Custom-Header"] = "aiohttp"
    return response

app = web.Application(middlewares=[custom_middleware])

WebSocketの利用

リアルタイム通信に適したWebSocketを簡単に実装できます。

async def websocket_handler(request):
    ws = web.WebSocketResponse()
    await ws.prepare(request)

    async for msg in ws:
        if msg.type == web.WSMsgType.TEXT:
            await ws.send_str(f"受信: {msg.data}")
    return ws

app.router.add_get("/ws", websocket_handler)

aiohttpを使う際の注意点

  1. 非同期I/Oの理解
    asyncioベースの設計が必要で、非同期処理の基本を理解しておくと効果的です。
  2. エラーハンドリング
    ネットワークエラーやタイムアウトを適切に処理しましょう。
  3. 適切なセッション管理
    ClientSessionを使い回さず、適切に閉じることが重要です。

まとめ

aiohttpは、Pythonで非同期Web開発を行うための強力なライブラリで、HTTPクライアントとサーバーの両方に対応しています。この記事で紹介した基本操作や応用例を活用し、効率的な非同期アプリケーションを構築してみましょう！

モバイルバージョンを終了