Plombery:Python定时任务调度系统构建与管理,轻松监控与执行Python脚本
Plombery 是一个基于 Python 的任务调度工具,它拥有一个简洁易用的 Web 界面和 REST API,让你轻松地管理和监控定时执行的 Python 脚本。无论你是需要定期清理数据、发送邮件通知,还是进行数据分析,Plombery 都能助你一臂之力。
Plombery 的优势
• 简洁高效:基于 Python 的任务定义,无需编写复杂的 HTML、JS 和 CSS 代码,简单易懂,上手快。
• 可视化管理:提供友好的 Web 界面,方便查看任务状态、运行日志、输出数据等。
• 灵活扩展:支持多种任务调度方式,包括 Interval、Cron 和 Date 触发器,并可以轻松定义复杂的管道流程。
• 安全可靠:使用 OAuth2 协议进行身份验证,保障数据安全。
• 强大功能:提供 REST API,方便与其他系统集成。
Plombery 的应用场景
• 定期数据分析和处理
• 自动化邮件发送
• 定时清理数据
• 自动备份系统数据
• 构建自动化工作流
Plombery 的使用指南
-
1. 安装 Plombery: 使用 pip 安装 Plombery:
pip install plombery
-
2. 创建任务: 在你的 Python 代码中定义任务,使用 Plombery 提供的 API 进行调度。
-
3. 启动 Plombery: 运行
plombery
命令启动 Plombery 服务器。 -
4. 访问 Web 界面: 浏览器访问
http://localhost:5000
即可访问 Plombery 的 Web 界面。
Plombery 的核心功能
• 任务调度: 使用 APScheduler 提供多种调度方式,包括 Interval、Cron 和 Date 触发器。
• 管道流程: 支持定义复杂的管道流程,多个任务可以串联起来执行。
• 参数化管道: 可以使用 Pydantic 对管道进行参数化,方便进行不同的配置。
• 手动运行: 可以通过 Web 界面手动运行指定的管道。
• 日志监控: 记录每个任务的运行日志,方便进行调试。
• 输出数据: 可以查看每个任务的输出数据,方便分析结果。
• 错误通知: 当任务运行出错时,会发送邮件通知到指定邮箱。
Plombery 的代码示例
from plombery importTask,Pipeline,IntervalTrigger
from plombery.utils import log
@Task
defmy_task():
log.info("Running my_task")
@Pipeline(trigger=IntervalTrigger(seconds=5))
defmy_pipeline():
my_task()
my_pipeline.run()
结语
Plombery 是一个高效、易用、功能强大的 Python 任务调度工具,它可以帮助你轻松地构建自动化工作流,提高工作效率。如果你正在寻找一款简单易用的 Python 任务调度工具,Plombery 是一个值得尝试的选择。
项目地址:https://github.com/lucafaggianelli/plombery
作者:墨鱼爆蛋