任务管理(含分布式)
2025年5月23日使用指南大约 4 分钟
任务管理
TaskPyro 专业版提供了强大的任务管理功能,支持跨多个工作节点的智能任务调度,为企业级应用提供高可用的多环境下的任务执行保障。
创建任务
在 TaskPyro 专业版中创建新任务时,您可以配置以下分布式特性:
基本配置
- 任务名称:为任务指定一个描述性的名称
- 项目选择:选择已创建的项目和对应的Python虚拟环境
- 执行命令:设置要执行的Python脚本命令(例如:
python script.py
或cd conf/aaa && python 1.py
等任意组合命令行),实在不清楚命令行如何写。可以查看项目上传后的目录 - 调度方式:配置任务的执行计划
分布式配置
- 节点选择策略:
- 自动选择:系统根据负载均衡算法自动选择最优节点(包括主控节点)
- 主控节点执行:指定任务在主控节点上执行
- 指定工作节点:手动指定特定的工作节点执行
- 节点组:选择预定义的节点组进行执行
- 平台限制:限制只在 Windows 或 Linux 节点执行
- 混合调度:允许任务在主控节点和工作节点间灵活调度

调度类型
TaskPyro支持多种调度类型,以满足不同的任务执行需求:
立即执行
不需要时间调度,立即执行一次任务。
间隔执行
按照固定的时间间隔重复执行任务。您可以设置:
- 间隔时长(支持秒、分钟、小时、天等单位)
- 首次执行时间
一次性执行
在指定的日期和时间执行一次任务。
Cron表达式
使用标准的Cron表达式来定义复杂的执行计划,支持:
- 分钟级别的精确控制
- 每天、每周、每月的定时执行
- 复杂的组合调度规则
任务列表
TaskPyro的主界面提供了丰富的任务调度信息和操作功能:
基本信息
- 任务名称和描述
- 所属项目和Python虚拟环境
- 执行命令和参数
- 下次执行时间
- 任务状态(活跃中、暂停、错误)
任务操作
- 暂停/启动调度任务
- 强制终止正在运行的任务实例
- 编辑任务配置
- 添加/编辑任务标签,方便分类管理

执行历史
每个任务都有详细的执行历史记录,您可以查看:
- 历次执行的开始和结束时间
- 任务执行状态(成功/失败)
- 执行耗时统计
- 错误信息(如果执行失败)

运行日志
TaskPyro提供了强大的日志查看功能:
日志筛选
- 按时间范围筛选
- 支持关键词搜索
- 按日志级别过滤(INFO、ERROR等)
实时查看
- 自动刷新最新日志
- 支持暂停自动刷新
- 可查看历史日志记录

并发实例管理
TaskPyro提供了灵活的并发实例管理功能:
- 默认情况下,如果上一个任务实例还在运行,新的调度时间到达时将跳过执行
- 通过设置最大并发实例数,可以允许同一个任务的多个实例同时运行
- 适用场景示例:
- 任务执行时间为1分钟
- 调度间隔为30秒
- 设置并发实例后,新的任务实例将在下一个时间点启动,不需要等待上一个实例完成
- 不设置并发实例时,将等待上一个实例完成后,在下一个调度点执行
任务编辑
您可以随时编辑已创建的任务:
- 修改任务名称和描述
- 更新Python环境配置
- 调整调度设置
- 启用/禁用并发实例
- 管理任务标签
通过这些功能,TaskPyro为您提供了一个完整的Python任务调度解决方案,帮助您高效管理自动化任务。