Prefect

Prefect 是一个现代化的 Python 工作流编排框架，让您可以轻松构建、调度和监控数据管道和自动化任务。 **核心功能**： - 🔄 **工作流编排**：定义复杂的任务依赖关系 - ⏰ **定时调度**：自动按时执行任务 - 🔁 **自动重试**：任务失败自动重试 - 📊 **可视化监控**：Web 界面查看运行状态 - 📝 **日志管理**：完整的执行日志记录 首次访问可能需要等待 **30-45 秒**服务完全启动。 在您的开发电脑上安装 Prefect 客户端： ```bash # 使用 pipx 安装（推荐） pipx install prefect 配置连接到您的服务器： # 替换为您的实际域名 prefect config set PREFECT_API_URL=https://your-domain.lzcapp/api 创建第一个工作流 ### 1. 基础示例 - Hello World 创建文件 `my_first_flow.py`： ```python from prefect import flow, task from datetime import datetime @task(name="问候") def say_hello(name: str): print(f"你好, {name}!") print(f"当前时间: {datetime.now()}") return f"Hello, {name}!" @flow(name="问候工作流") def hello_flow(name: str = "世界"): message = say_hello(name) print(f"消息: {message}") return message if __name__ == "__main__": # 运行工作流 hello_flow(name="天天") ``` 运行： ```bash python3 my_first_flow.py ``` ### 2. 在 Dashboard 查看结果 1. 打开 Web 界面 2. 点击左侧 **"Runs"** 菜单 3. 查看刚才运行的工作流详情、日志和状态