Azkaban-實戰（三）java操作任務
使用Azkaban調度java程序
1）編寫java程序
1 package azkaban; 2
3 import java.io.FileOutputStream; 4 import java.io.IOException; 5
6 public class AzkabanTest { 7 public void run() throws IOException { 8 // 根據需求編寫具體代碼
9 FileOutputStream fos = new FileOutputStream("/opt/module/azkaban/output.txt"); 10 fos.write("this is a java progress".getBytes()); 11 fos.close(); 12 } 13
14 public static void main(String[] args) throws IOException { 15 AzkabanTest azkabanTest = new AzkabanTest(); 16 azkabanTest.run(); 17 } 18 }
2）將java程序打成jar包，創建lib目錄，將jar放入lib內
3）編寫job文件
[itstar@bigdata111 jobs]$ vi azkabanJava.job
#azkabanJava.job
type=javaprocess
java.class=AzkabanTest(全類名)
classpath=/opt/module/azkaban/lib/*
**********************************************************************
這里我直接用Notepad++編寫的，之后直接用壓縮軟件壓縮成.zip文件即可：
4）將job文件打成zip包
[itstar@bigdata111 jobs]$ zip azkabanJava.zip azkabanJava.job
adding: azkabanJava.job (deflated 19%)
5）通過azkaban的web管理平台創建project並上傳job壓縮包，啟動執行該job
[itstar@bigdata111 azkaban]$ cat /opt/module/azkaban/output.txt
