Xử lý Tác vụ Nền Bất đồng bộ với BackgroundTasks (Async BackgroundTasks Execution)

Mục tiêu kiến thức

• Sử dụng BackgroundTasks tích hợp sẵn trong FastAPI để thực thi các tác vụ tốn thời gian (gửi email, ghi log, đồng bộ) sau khi response đã gửi trả xong.

Mô tả bài toán

Viết hàm create_audit_background_app(audit_log: list) -> FastAPI:

• Hàm worker chạy nền:

def write_audit_log(email: str, message: str, audit_log: list): Thêm dict {"email": email, "message": message, "status": "DELIVERED"} vào audit_log.

• Tạo endpoint:

POST /notifications/send:

• Tham số: payload: dict (chứa email: str và message: str), background_tasks: BackgroundTasks.
• Đăng ký task nền: background_tasks.add_task(write_audit_log, payload["email"], payload["message"], audit_log).
• Trả về ngay lập tức với HTTP 202 Accepted:

{"status": "queued", "recipient": payload["email"]}.

Ràng buộc

• Thời gian chạy tối đa: 1000ms.
• Giới hạn bộ nhớ: 256MB.
• Dữ liệu đầu vào tuân thủ đúng kiểu dữ liệu và miền giá trị được mô tả.