MENU
  1. ホーム
  2. Python
  3. PythonでAPIとイベントドリブンアーキテクチャを活用する方法

PythonでAPIとイベントドリブンアーキテクチャを活用する方法

Python

PythonでAPIを扱い、イベントドリブンアーキテクチャを実装する方法について詳しく解説します。具体的なコード例とその解説、さらには応用例を2つ含めています。

目次

APIとイベントドリブンアーキテクチャの基本

API（Application Programming Interface）はソフトウェアコンポーネント間のインターフェースであり、一方のソフトウェアが他方と通信を行う手段を提供します。イベントドリブンアーキテクチャは、システムがイベントに基づいて動作する設計パターンです。このアーキテクチャスタイルは、非同期処理やマイクロサービスにおいて非常に有用です。

APIとPython

PythonはAPIとの連携が非常に簡単で、多くのライブラリが提供されています。特に`requests`ライブラリはHTTP APIとの通信を簡単に実装できます。

HTTP GETリクエストの基本形

`sCode`
import requests

# APIエンドポイント
url = “https://jsonplaceholder.typicode.com/todos/1”

# GETリクエスト
response = requests.get(url)

# JSONレスポンスを取得
data = response.json()

# 出力
print(data)

このコードは、指定されたURLのAPIにGETリクエストを行い、そのレスポンスを受け取ります。

イベントドリブンアーキテクチャとPython

イベントドリブンアーキテクチャは、特定のイベント（トリガー）に応じて処理を行うプログラムの設計スタイルです。Pythonでは`asyncio`や外部ライブラリの`Celery`などで簡単に実装することができます。

asyncioを使った非同期処理

`sCode`
import asyncio

async def my_event_handler(event):
print(f”Handling event: {event}”)

async def main():
for i in range(3):
await my_event_handler(f”Event-{i}”)

# イベントループを実行
asyncio.run(main())

このコードは非同期に3つのイベントを処理する例です。

応用例1: APIと非同期処理の組み合わせ

APIからデータを非同期に取得して、それをイベントドリブンの形で処理する例を見てみましょう。

`sCode`
import asyncio
import requests

async def fetch_data_from_api(api_url):
# 非同期処理のシミュレーション
loop = asyncio.get_event_loop()
await loop.run_in_executor(None, lambda: requests.get(api_url))

async def main():
urls = [“https://jsonplaceholder.typicode.com/todos/1”,
“https://jsonplaceholder.typicode.com/todos/2”]
for url in urls:
await fetch_data_from_api(url)

asyncio.run(main())