阿里中间件自研的分布式任务调度平台

1.产品简介

.0是阿里后边件自研的基于Akka构架的新一代分布式任务调度平台,提供定时、任务编排、分布式跑批等功能。使用.0,您可以在控制台配置管理您的定时任务,查询历史执行记录,查看运行日志。凭借.0,您还可以通过工作流进行任务编排和数据传递。.0还提供了简略易用的分布式编程模型任务平台,简略几行代码就可以将海量数据分布式到多台机器上执行。

.0提供了任务调度与执行的一整套解决方案,在阿里巴巴企业集团内部广泛使用并久经考验,具备高牢靠、海量任务、秒级别调度等能力。

2.背景

.0是.0(DTS)的下一代产品,辅以全新的构架,是全新自研的下一代分布式任务调度平台,不但解决了老产品的功耗难题,还提供了更多更快更强的能力。

3.功能

3.1强悍的定时调度器

3.1.1

支持unix式子,不支持秒级别。

3.1.2Fixedrate

众所周知,应当被60整除,例如想每隔40分钟跑一次,cron不支持。Fixedrate专门拿来做定期线程,式子简略,不支持秒级别。

3.1.3Fixeddelay

适宜对实时性要求比较高的业务,例如每天执行完成隔10秒再跑,这么delay特别适于你。使得delay能支持到秒级别。

3.1.4月历

支持多种月历,还可以自定义导出月历。诸如金融业务还要在每位交易日执行。

3.1.5时区

跨国的业务,还要在每位国家的时区定时执行某个任务。

3.2任务编排

支持工作流(DAG)进行任务编排,操作简略,后端直接单手操作拖拖曳拽即可。具体的任务状态图能一目了然听到下游任务为何没跑。

3.3任务类别

支持多种任务类别,可以无限扩充。

3.4执行方法&分布式编程模型

3.4.1执行方法

3.4.2分布式编程模型

3.5强悍的维保能力

3.6数据时间

.0可以处理有数据状态的任务。争创任务的时侯可以填数据偏斜。例如一个任务是每次00:30运行,然而实际上要处理上每天的数据,就可以往前偏斜一个小时。运行时间不变,执行的时侯通过.()荣获的就是前两天23:30。

3.7重刷数据

倘若任务具备了数据时间,一定少不了重刷数据。例如一个任务/工作流最终形成一个报表,并且业务发生变更(新增一个数组),或则发觉上一个月的数据都有错误,这么就须要重刷过去一个月的数据。

通过重刷数据功能,可以重刷这些任务/工作流的数据(只支持天级别),每位例子都是不同的数据时间。

3.8失败手动重试

3.9支持原生

之前的老产品.0(DTS)和的结合十分暴力,对bean的命名有强要求任务平台,一直碰到注入失败的问题。.0支持原生句型,接入格外的便捷。

3.10报案监控

标签: 任务 调度 定时 编排 级别

  • 评论列表 (0)

留言评论