azkaban介绍

素颜马尾好姑娘i 2024-03-22 17:02 39阅读 0赞

**目录**

为什么需要工作流调度系统

什么是azkaban

azkaban适用场景

azkaban特点

常见的工作流调度系统

azkaban和Ooize特性对比

azkaban的架构

azkaban调度的任务有可能有那些类型

总结

--------------------

### 为什么需要工作流调度系统 ###

一个完整的大数据分析系统，必然由很多任务单元 (如数据收集、数据清洗、数据存储、数据分析等) 组成，所有的任务单元及其之间的依赖关系组成了复杂的工作流。复杂的工作流管理涉及到很多问题：

如何定时调度某个任务？  
如何在某个任务执行完成后再去执行另一个任务？  
如何在任务失败时候发出预警？  
…  
面对这些问题，工作流调度系统应运而生。Azkaban 就是其中之一。

### 什么是azkaban ###

Azkaban是由Linkedin公司推出的一个批量工作流任务调度器，主要用于在一个工作流内以一个特定的顺序运行一组工作和流程，它的配置是通过简单的key:value对的方式，通过配置中的dependencies 来设置依赖关系。Azkaban使用job配置文件建立任务之间的依赖关系，并提供一个易于使用的web用户界面维护和跟踪你的工作流。

### azkaban适用场景 ###

根据以上业务场景： （2）任务依赖（1）任务的结果，（3）任务依赖（2）任务的结果，（4）任务依赖（3）任务的结果，（5）任务依赖（4）任务的结果。一般的做法是，先执行完（1）再执行（2），再一次执行（3）（4）（5）。这样的话，整个的执行过程都需要人工参加，并且得盯着各任务的进度。但是我们的很多任务都是在深更半夜执行的，通过写脚本设置crontab执行。其实，整个过程类似于一个有向无环图（DAG）。每个子任务相当于大任务中的一个节点，也就是，我们需要的就是一个工作流的调度器，而Azkaban就是能解决上述问题的一个调度器。

### azkaban特点 ###

1.  兼容任何版本的Hadoop
2.  易于使用的Web用户界面
3.  简单的工作流的上传
4.  方便设置任务之间的关系
5.  调度工作流
6.  模块化和可插拔的插件机制
7.  认证/授权（权限的工作）
8.  能够杀死并重新启动工作流
9.  有关失败和成功的电子邮件提醒
10. SLA 警报和自动查杀失败任务
11. 重试失败的任务
12. Azkaban 的设计理念是在保证功能实现的基础上兼顾易用性，其页面风格清晰明朗，下面是其 WEB UI 界面![c5eb960492c146dd8fbd3cba953bc450.png][]

### 常见的工作流调度系统 ###

1）简单的任务调度：直接使用crontab实现;

2）复杂的任务调度：开发调度平台或使用现成的开源调度系统，比如Ooize、Azkaban等

### azkaban和Ooize特性对比 ###

<table style="width:555px;"> 
 <thead> 
  <tr> 
   <th style="width:188px;">特性</th> 
   <th style="width:197px;">Hamake</th> 
   <th style="width:169px;">Oozie</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td style="width:188px;">工作流描述语言</td> 
   <td style="width:197px;">XML</td> 
   <td style="width:169px;">XML (xPDL based)</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">依赖机制</td> 
   <td style="width:197px;">data-driven</td> 
   <td style="width:169px;">explicit</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">是否要web容器</td> 
   <td style="width:197px;">NO</td> 
   <td style="width:169px;">YES</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">进度跟踪</td> 
   <td style="width:197px;">console/log messages</td> 
   <td style="width:169px;">web page</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">Hadoop job调度支持</td> 
   <td style="width:197px;">no</td> 
   <td style="width:169px;">YES</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">运行模式</td> 
   <td style="width:197px;">command line utility</td> 
   <td style="width:169px;">daemon</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">Pig支持</td> 
   <td style="width:197px;">yes</td> 
   <td style="width:169px;">yes</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">事件通知</td> 
   <td style="width:197px;">no</td> 
   <td style="width:169px;">no</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">需要安装</td> 
   <td style="width:197px;">no</td> 
   <td style="width:169px;">yes</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">支持的hadoop版本</td> 
   <td style="width:197px;">0.18+</td> 
   <td style="width:169px;">0.20+</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">重试支持</td> 
   <td style="width:197px;">no</td> 
   <td style="width:169px;">workflownode evel</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">运行任意命令</td> 
   <td style="width:197px;">yes</td> 
   <td style="width:169px;">yes</td> 
  </tr> 
  <tr> 
   <td style="width:188px;">Amazon EMR支持</td> 
   <td style="width:197px;">yes</td> 
   <td style="width:169px;">no</td> 
  </tr> 
 </tbody> 
</table>

### azkaban的架构 ###

![859ddb6224a34636acb4e5e24e206b52.png][]

**azkabanWebServer**

azkabanWebServer是整个Azkaban工作流系统的主要管理者，它负责用户登录认证、project管理、定时执行工作流、跟踪工作流执行进度等一系列任务。

**azkabanExecutorServer**

负责具体的工作流的提交、执行，它们通过MySQL数据库来协调任务的执行。

**关系型数据库（MySQL）**

存储大部分执行流状态，azkabanWebServer和azkabanExecutorServer都需要访问数据库。

### azkaban调度的任务有可能有那些类型 ###

*  shell脚本
 *  java程序
 *  MR程序
 *  spark程序
 *  hive的sql
 *  python脚本
 *  sqoop任务

### 总结 ###

如果工作流不是特别复杂，推荐使用轻量级的 Azkaban，主要有以下原因：

安装方面：Azkaban 3.0 之前都是提供安装包的，直接解压部署即可。Azkaban 3.0 之后的版本需要编译，这个编译是基于 gradle 的，自动化程度比较高；  
页面设计：所有任务的依赖关系、执行结果、执行日志都可以从界面上直观查看到；  
配置方面：Azkaban Flow 1.0 基于 Properties 文件来定义工作流，这个时候的限制可能会多一点。但是在 Flow 2.0 就支持了 YARM。YARM 语法更加灵活简单，著名的微服务框架 Spring Boot 就采用的 YAML 代替了繁重的 XML。

[c5eb960492c146dd8fbd3cba953bc450.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/76fb02283b984a2fb618e6c26774f6ed.png
[859ddb6224a34636acb4e5e24e206b52.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/6594f235be0a46f7bbed9911265565bd.png