SuperAPI AI 工具集

task-scheduling

部署与运维

查看项目

更新于 10-16 04:34

技能介绍

用途:当工作需要稍后运行(如 24 小时后发提醒)、按计划运行(夜间汇总、每小时 cron)或重复运行(每 5 分钟轮询),且需要把作业可靠分配给 worker 池、需要优先级/公平性、或需要恰好一次执行时使用。该技能构建在消息流队列之上:队列负责传输,此技能补充调度、租约、优先级与任务级幂等。

主要能力:调度触发方式(单机 cron、分布式 HA cron、延迟队列/定时器、工作流 DAG);worker 分配(拉取式租约、推式派发);优先级与公平调度(优先级队列、加权/公平调度)。

关键约定:同步返回结果、单个无需调度与优先级的异步步骤、单机单个周期作业、需要回滚的多步长流程,均不适用;不要为假设的未来批量作业预先引入 Airflow/Celery。

必要用法:先明确触发类型、恰好一次还是至少一次、延迟预算、优先级/公平性、任务时长、幂等键。默认采用拉取式 worker 租约与可见性超时;可见性超时应高于 p99 任务时长,长任务用心跳续租;任务必须幂等去重;调度器需单 leader 选举;重试要有退避与抖动并进入死信队列;监控最老到期作业年龄、队列深度、租约过期/重投率、重试与 DLQ 率等。worker 数量可用 Little 定律估算:在途作业 = 到达率 × 平均时长。

限制:资料未提供具体价格、平台支持情况、安装命令与可用 provider 列表,也未给出代码示例;仅提到可查阅 references 下的深入文档与 provider 映射文件(generic、aws、azure、gcp、temporal)。