用途:协调多个后台 worker,适合需要统一调度、处理相互依赖、避免并发冲突并自动停用故障任务的场景。
主要能力:按间隔调度(scheduled/triggered/continuous 三种执行模式);通过 dependsOn 声明依赖、blocks 声明互斥;设置超时、重试与优先级;连续失败达到阈值后自动禁用;提供 triggerWorker、enableWorker、disableWorker 与 getStatus 等控制与监控接口。
使用方式:注册 worker 时传入执行函数与配置(intervalSeconds、timeoutSeconds、maxRetries、priority、maxConsecutiveFailures、dependsOn、blocks),调用 start() 启动、stop() 优雅关闭。示例:orchestrator.registerWorker('process-data', processDataWorker, { intervalSeconds: 120, dependsOn: ['fetch-data'] }); await orchestrator.start();
适用场景:数据抓取后处理、定时清理、顺序工作流、互斥任务等。
限制:资料未提供安装命令、包名、版本、收费与平台信息;实现细节以资料中的 TypeScript 与 Python 代码为准。