azkaban 2.0, 对应的是azkaban project 1.0 azkaban支持 properties配置文件，也支持yml配置文件！

azkaban3.0 , 对应的是azkaban project 2.0 azkaban默认支持yml配置文件！

mysql -u root -p 

2.2创建Azkaban数据库

Azkaban Executor Server处理工作流和作业的实际执行。

#设置时区
default.timezone.id=Asia/Shanghai
#...
azkaban.webserver.url=http://hadoop102:8081

#...
database.type=mysql
mysql.port=3306
mysql.host=主机名
mysql.database=mysql数据库名
mysql.user=使用者user
mysql.password=mysql密码
mysql.numconnections=100
executor.port=12321

3.1同步azkaban-exec到所有节点

xsync /opt/module/azkaban/azkaban-exec

user.manager.xml.file=conf/azkaban-users.xml

相对的是，当前你所在的目录，也就是执行start-exec.sh命令时，所在的目录

举例： 在 /home/user   启动azkaban
此时：   user.manager.xml.file=/home/user/conf/azkaban-users.xml
报错，找不到此文件

如果在 azkaban的家目录启动：
user.manager.xml.file=/opt/module/azkaban/azkaban-exec/conf/azkaban-users.xml

curl -G "hadoop102:12321/executor?action=activate" && echo

{"status":"success"}

				
				

					... 
				

				

					default.timezone.id=Asia/Shanghai 
				
#配置同上：
				

					database.type=mysql 
				

				

					mysql.port=3306 
				

				

					mysql.host=
				

				

					mysql.database= 
				

				

					mysql.user= 
				

				

					mysql.password=
				

				

					mysql.numconnections=100 
				

				

					...
				

				

					


				

				

					azkaban.executorselector.filters=StaticRemainingFlowSize,CpuStatus
				

				

					


				

<azkaban-users>
  <user groups="azkaban" password="azkaban" roles="admin" username="azkaban"/>
  <user password="metrics" roles="metrics" username="metrics"/>
  <user password="mysqlpassword" roles="metrics,admin" username="mysql_user"/>

  <role name="admin" permissions="ADMIN"/>
  <role name="metrics" permissions="METRICS"/>
</azkaban-users>

5.3启动azkaban-web

Azkaban使用

 HelloWorld案例

azkaban-flow-version: 2.0

nodes:
  - name: jobA
    type: command
    config:
      command: echo "Hello World"

作业依赖案例

1.修改basic.flow为如下内容

nodes:
  - name: jobC
    type: command
    # jobC 依赖 JobA和JobB
    dependsOn:
      - jobA
      - jobB
    config:
      command: echo "I’m JobC"

  - name: jobA
    type: command
    config:
      command: echo "I’m JobA"

  - name: jobB
    type: command
    config:
      command: echo "I’m JobB"

自动失败重试案例

nodes:
  - name: JobA
    type: command
    config:
      command: sh /not_exists.sh
      retries: 3
      retry.backoff: 10000

 手动失败重试案例

需求：JobA=》JobB（依赖于A）=》JobC=》JobD=》JobE=》JobF。生产环境，任何Job都有可能挂掉，可以根据需求执行想要执行的Job。

1.编译配置流

可以根据需求选择性执行对应的任务。

具体步骤：