在 FastAPI 中使用定时任务时，如果需要捕获所有定时任务的异常并发送邮件，可以通过以下步骤实现： 1. **设置定时任务**：可以使用 `APScheduler` 或者 `Celery` 来管理定时任务。 2. **捕获异常**：通过装饰器或者上下文管理器捕获任务中的异常。 3. **发送邮件**：可以使用 `smtplib` 或者第三方库如 `fastapi-mail` 发送邮件。 以下是使用 `APScheduler` 和 `smtplib` 的完整实现示例： ### 代码实现 ```python from fastapi import FastAPI from apscheduler.schedulers.background import BackgroundScheduler import smtplib from email.mime.text import MIMEText from email.mime.multipart import MIMEMultipart import traceback app = FastAPI() # 配置邮件信息 SMTP_SERVER = "smtp.example.com" SMTP_PORT = 587 EMAIL_USER = "your_email@example.com" EMAIL_PASSWORD = "your_password" RECIPIENT_EMAIL = "recipient_email@example.com" # 定义发送邮件函数 def send_error_email(subject, body): msg = MIMEMultipart() msg['From'] = EMAIL_USER msg['To'] = RECIPIENT_EMAIL msg['Subject'] = subject msg.attach(MIMEText(body, 'plain')) try: server = smtplib.SMTP(SMTP_SERVER, SMTP_PORT) server.starttls() server.login(EMAIL_USER, EMAIL_PASSWORD) text = msg.as_string() server.sendmail(EMAIL_USER, RECIPIENT_EMAIL, text) server.quit() except Exception as e: print(f"Failed to send email: {e}") # 定义一个带异常捕获的装饰器 def catch_exceptions(func): def wrapper(*args, **kwargs): try: return func(*args, **kwargs) except Exception as e: error_message = f"Error in task {func.__name__}: {str(e)}\n\nTraceback:\n{traceback.format_exc()}" print(error_message) # 打印错误日志 send_error_email("Task Error", error_message) # 发送邮件 return wrapper # 示例定时任务 @catch_exceptions def example_task(): print("Running example task...") # 模拟一个异常 raise ValueError("Something went wrong!") # 初始化调度器 scheduler = BackgroundScheduler() @app.on_event("startup") def start_scheduler(): scheduler.add_job(example_task, "interval", seconds=10) # 每隔10秒运行一次 scheduler.start() print("Scheduler started.") @app.on_event("shutdown") def shutdown_scheduler(): scheduler.shutdown() print("Scheduler shut down.") ``` --- ### 代码解释 1. **邮件发送函数 (`send_error_email`)**： - 使用 `smtplib` 构建邮件内容并通过 SMTP 协议发送。 - 邮件内容包括任务名称、错误信息和完整的堆栈跟踪信息。 2. **异常捕获装饰器 (`catch_exceptions`)**： - 包裹定时任务函数，捕获任何未处理的异常。 - 将异常信息记录到控制台，并调用 `send_error_email` 函数发送邮件。 3. **定时任务 (`example_task`)**： - 示例任务，模拟了一个异常以测试异常捕获和邮件发送功能。 4. **调度器配置 (`BackgroundScheduler`)**： - 在应用启动时初始化调度器，并添加定时任务。 - 在应用关闭时优雅地关闭调度器。 --- ###