Azkaban实战-java操作任务

使用Azkaban调度java程序

1.编写java程序

import java.io.FileOutputStream;
import java.io.IOException;
public class AzkabanTest {

      public void run() throws IOException {

      // 根据需求编写具体代码

          FileOutputStream fos = new FileOutputStream("/opt/module/azkaban/output.txt");

          fos.write("this is a java progress".getBytes());

          fos.close();

      }

      public static void main(String[] args) throws IOException {

          AzkabanTest azkabanTest = new AzkabanTest();

          azkabanTest.run();
      }
}

2.将java程序打成jar包，创建lib目录，将jar放入lib内

mkdir lib

cd lib/

ll

3.编写job文件

vi azkabanJava.job

添加内容：

#azkabanJava.job
type=javaprocess
java.class=AzkabanTest
classpath=/opt/module/azkaban/lib/*

java.class：全类名

4.将job文件打成zip包

zip azkabanJava.zip azkabanJava.job 

5.通过azkaban的web管理平台创建project并上传job压缩包，启动执行该job

创建项目 上传 执行

6.结果：

cat /opt/module/azkaban/output.txt

结果 结果