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
