主要服务
dag：包括 task、operator、sensor 模块 配置 dag、task、operatorschedule：包括 control 模块 启动 暂停 恢复等 控制dag任务启动worker：执行 task 触发sensor状态更新
operator
operator（操作器）：定义任务该以哪种方式执行
主要有以下四种
function_operator：js函数shell_operator：执行shell命令http_operator：发送http请求seneca_operator：发送seneca请求
所有的operator有 default_args（默认参数） 和 dynamic_args（动态参数） 和 schedule_args 三种参数
优先级： schedule_args > dynamic_args > default_args
schedule_args 从schedule start启动入口传入到第一批task 然后依次往后续的task传递
dynamic_args支持2种类型：
- 从指定的url获取 get
- 从指定的seneca 接口获取
default_args 创建task的operator时输入
sensor
创建task时系统自动创建sensor，sensor是task任务可执行的感知器 ，task可执行满足2个条件
- 所有前向任务执行完毕
- 任务自身的条件满足
任务自身的条件在创建task时指定，sensor支持多种条件：
- 到达指定时间范围
- 指定url get返回结果满足要求
- 调用seneca接口返回结果满足要求
schedule
- start 多种条件启动dag任务
- stop 停止
- pause 暂停调度
- resume 恢复调度
start 支持多个参数
- 调度策略参数
调度策略：
- 指定时间执行 周期间隔执行固定次数
- 立即执行
- 监听http事件触发执行
- 监听seneca事件触发执行
执行参数策略：
- 通过start接口传入固定使用
- 指定url每次执行返回
- 指定seneca接口每次执行返回
dag调度后 从数据库 load到redis，通过多个worker执行
worker要设置task状态，通知相应的sensor，判断sensor条件是否满足
task的状态：
- 暂停 任务暂停，不调度
- 调度中 任务可执行，等待worker执行
- 执行中 分配到worker，worker正在执行任务
- 等待 sensor条件未满足，任务等待
- 结束 任务执行完毕
- 异常 任务执行异常
sensor的动态参数 和opertor的动态参数 $.sche_parameter.status 这种方式
schedule调度进程 判断sensor条件满足后，触发动态参数解析，完成后设置实际参数到redis对应的task缓存中 然后worker调度执行
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请联系我们举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/214913.html原文链接：https://javaforall.net
