Azkaban02:配置job工作流

在前面Azkaban部署并啟動后,訪問:http://master:8081/
查看azkaban-users.xml文件,登錄用戶和密碼如下:

1.創(chuàng)建單任務(wù):

1.1 在登錄后的界面,點(diǎn)擊創(chuàng)建按鈕,創(chuàng)建一個任務(wù):


1.2 創(chuàng)建三個文件并一起壓縮為test.zip中(測試方式1)
文件1 test.flow:

---
config:
  #failure.emails: xx@xx

nodes:
  - name: test
    type: command
    config:
      command: sh test.sh

文件2 test.project:

azkaban-flow-version: 2.0

文件3 test.sh

#!/bin/bash

yesterday=`date -d "-1 day" +"%Y%m%d"`

echo "Hello , $yesterday"

1.3 web端上傳zip包
任務(wù)上傳成功:



1.4 執(zhí)行
step1:



step2:

step3:

執(zhí)行成功:


補(bǔ)充:腳本編寫方式二:
新建command.job:

type=command
command=echo "hello Azkaban~~"

打包為zip文件,上傳,執(zhí)行,成功執(zhí)行:


2.創(chuàng)建多任務(wù)依賴:

創(chuàng)建foo.job文件:

type=command
command=echo "Hello 123"

創(chuàng)建bar.job文件:

type=command
dependencies=foo
command=echo "Hello 456"

壓縮打包為dep.zip,上傳,執(zhí)行:
step1:



step2:



step3:

step4:

step5:


?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

友情鏈接更多精彩內(nèi)容