技术编程|开源调度系统:liteflow控制台功能
liteflow整体分为两个模块 , 控制台以及执行者;其中控制台负责任务的关系以及执行的调度 , 执行者负责任务的具体执行 。 控制台中主要的功能围绕在任务以及任务流 。
一、主要功能介绍
1.任务
1)任务创建需要根据任务的周期(分、时、天等)来设置 , 同时需要指定任务执行的cron表达式;其中任务周期是用来任务上下游间关联的依据 , 例如用来计算一周的pv总量(即上游任务为天 , 下游任务为周) , 这时会依据周期 , 下游任务会自动关联上上游任务周一到周日的任务 , 只有上游的七个任务都执行成功后下游才会执行 , 这样就能保证数据不会出现漏掉的情况
2)选择任务运行的插件 , 即任务执行类型(hive、python、shell等) , 任务的执行插件主要是执行者来实现 , 通过容器、插件、任务详情来实现任务的执行 , 这个后续会有具体介绍
从表单中可以看出 , 任务需要指定是否可以并发 , 并发指的是同一时间同一个任务的不同任务版本是否可以同时运行 , 如果为否 , 需要指定运行策略 。 1)忽略:即忽略正在运行的任务 , 将其设置为成功状态 , 然后当前任务版本再执行 , 这种情况适合任务运行一次和多次没有区别的情况 , 例如统计统计某网站当天的pv数时 。 2)等待:需要等待上一个任务版本执行完成后 , 再执行当前任务 , 这种情况适合任务执行以来上一次任务执行后产生的数据 , 例如统计每个小时环比变化数据时 。
本文插图
本文插图
【技术编程|开源调度系统:liteflow控制台功能】
二、任务流
1.创建任务流
在大数据ETL相关工作中 , 需要依赖任务流来保证各种数据层的计算 , 也就是我们现在提到的任务流 , 任务流的核心是DAG原理来保证任务的按一定的规则来运行 , 任务流创建后 , 需要将已添加的任务通过图形界面建立好关联
本文插图
1)通过图形界面编辑任务流
通过将鼠标在任务节点上右键可以添加任务 , 来实现任务的上下游关系
本文插图
本文插图
本文插图
2)任务流修复
在日常工作很多情况下需要对任务进行再一次修复 , 通过图形界面可以实现任务流中所有任务、从某个节点、仅某个任务的修复;任务流的修复会根据主节点任务来完成数据的展示 , 依据主节点任务的任务版本以及任务流中任务关系来完成某个版本下任务流下的任务实例关系
本文插图
总结:
liteflow整个的核心其实是通过任务流来保证各个任务按照DAG的关系实现任务的顺序执行 , 以保证每个任务对应能够在上游任务数据ready的前提下再去执行 , 从而保证数据的一致性
推荐阅读
- 科学探索|新技术能快速将海水变成饮用水
- 美将38家华为子公司列入实体清单|美将38家华为子公司列入实体清单,限制它们获得某些“敏感技术”
- 现代迎来技术“爆发”解读第十代索纳塔动力系统
- 栽培技术|发展林下树下黑木耳栽培技术,促进林业生产发展,增加经济收入
- 隐身能力太差,俄军仍采购76架苏57战机,新技术加持或超越F35
- 法制|未成年小伙网上学偷车技术 第一次作案就被抓了
- 美国发射的帕克太阳探测器,为什么不怕热?技术实在太牛
- 小米科技|官方评判小米,始终没有掌握核心技术,依旧是组装公司
- 郓城县召开纺织行业技术交流大会
- 鼎盛网军事|单发命中率达到90%,我国引进法国技术生产一导弹,高原实战逞威
