azkaban入门

步骤: 1.创建一个文件夹 2.在文件夹中创建.project结尾的文件 3.在文件中添加内容 azkaban-flow-version: 2.0 4.创建.f

步骤:
1.创建一个文件夹
2.在文件夹中创建.project结尾的文件
3.在文件中添加内容 azkaban-flow-version: 2.0
4.创建.flow结尾的文件(可以放多个job)
5.在文件中添加以下内容

  nodes:- name: jobAtype: commandconfig:command: echo "This is an echoed text."

6.把以上两个文件打包成zip压缩包
7.上传到Azkaban-Web界面

执行sh命令

nodes:- name: jobAtype: commandconfig:command: echo "This is an echoed text."

执行shell脚本

nodes:- name: jobAtype: commandconfig:command: sh ./demo3/bin/showpath.sh

执行class类

nodes:- name: jobAtype: javaprocessconfig:classpath: ./demo4/lib/*java.class: com.yh.azkaban.Test1

两个无关job

nodes:- name: jobAtype: javaprocessconfig:classpath: ./demo5/lib/*java.class: com.yh.azkaban.Test1- name: jobBtype: commandconfig:command: sh ./demo5/bin/showpath.sh

多个job顺序执行


nodes:- name: jobAtype: javaprocessconfig:classpath: ./demo6/lib/*java.class: com.yh.azkaban.Test1- name: jobBtype: commandconfig:command: sh ./demo6/bin/showpath.sh- name: jobCtype: noopdependsOn:- jobA- jobB- name: jobDtype: commanddependsOn:- jobCconfig:command: echo 'jobA,jobB,jobC is over'

内嵌flow执行


nodes:- name: jobCtype: noopdependsOn:- jobA- jobB- jobE- name: jobAtype: javaprocessconfig:classpath: ./demo7/lib/*java.class: com.yh.azkaban.Test1- name: jobBtype: commandconfig:command: sh ./demo7/bin/showpath.sh- name: jobDtype: commanddependsOn:- jobCconfig:command: echo 'jobA,jobB,jobC is over'- name: jobEtype: flownodes:- name: jobE1type: commandconfig: command: echo 'jobE1'- name: jobE2type: commandconfig: command: echo 'jobE2'