Bài 16. Gọi API web với requests và httpx

Khái niệm và lý thuyết

Một lời gọi API gồm: phương thức (GET lấy, POST tạo, PUT/PATCH sửa, DELETE xóa), URL, header (định dạng, xác thực), body (dữ liệu gửi đi). Máy chủ trả về mã trạng thái và thân phản hồi, thường là JSON.

GET với requests

import requests
r = requests.get(
    "https://api.open-meteo.com/v1/forecast",
    params={"latitude": 21.33, "longitude": 103.91, "current": "temperature_2m"},  # Sơn La
    timeout=10,
)
r.raise_for_status()                  # ném lỗi nếu 4xx/5xx
du_lieu = r.json()
print("Nhiệt độ Sơn La:", du_lieu["current"]["temperature_2m"], "°C")

POST và xác thực

import os
API_KEY = os.environ["MY_API_KEY"]    # đọc từ biến môi trường, không ghi thẳng vào mã
r = requests.post(
    "https://httpbin.org/post",
    json={"ten": "An", "diem": 9},
    headers={"Authorization": f"Bearer {API_KEY}"},
    timeout=10,
)
print(r.status_code, r.json()["json"])

Xử lý lỗi

from requests.exceptions import RequestException
def lay_json(url, lan_thu=3):
    for i in range(lan_thu):
        try:
            r = requests.get(url, timeout=5)
            r.raise_for_status()
            return r.json()
        except RequestException as e:
            print(f"Lần {i + 1} lỗi: {e}")
    return None

httpx: bất đồng bộ

import asyncio, httpx
async def main():
    async with httpx.AsyncClient(timeout=10) as client:
        urls = [f"https://jsonplaceholder.typicode.com/posts/{i}" for i in range(1, 6)]
        kq = await asyncio.gather(*(client.get(u) for u in urls))
        print([r.json()["title"][:20] for r in kq])
asyncio.run(main())

httpx có API gần giống requests nhưng hỗ trợ async, gọi song song nhiều API nhanh hơn nhiều (chi tiết async ở Bài 19).