当前位置:网站首页>Azkaban实战
Azkaban实战
2022-07-05 02:41:00 【一个正在努力的菜鸡】
单一job案例
1.创建job描述文件
- vim job1.job
#first.job
type=command
command=echo 'this is my first job'
2.将job资源文件打包成zip文件
- 安装zip,unzip命令
yum install -y unzip zip
- 压缩
zip job1.zip job1.job
- Azkaban上传的工作流文件只支持xxx.zip文件,zip应包含xxx.job运行作业所需的文件和任何文件(文件名后缀必须是.job,否则无法识别),作业名称在项目中必须是唯一的
3.通过azkaban的web管理平台创建project并上传job的zip包
- 创建project
- 上传zip包
- 启动执行该job
- Job执行成功
- 点击查看job日志
多job工作流案例
1.创建job描述文件
- 第一个job:start.job
vim start.job
#start.job
type=command
command=touch /usr/local/azkaban/jobs/t2test.txt
- 第二个job:step1.job依赖start.job
vim step1.job
#step1.job
type=command
dependencies=start
command=echo "this is step1 job"
- 第三个job:step2.job依赖start.job
vim step2.job
#step2.job
type=command
dependencies=start
command=echo "this is step2 job"
- 第四个job:finish.job依赖step1.job和step2.job
vim finish.job
#finish.job
type=command
dependencies=step1,step2
command=echo "this is finish job"
2.将job资源文件打包成zip文件
- zip jobs.zip start.job step1.job step2.job finish.job
3.通过azkaban的web管理平台创建project并上传job的zip包
Java操作任务
1.编写java程序
import java.io.FileOutputStream;
import java.io.IOException;
public class AzkabanTest {
public void run() throws IOException {
FileOutputStream fos = new FileOutputStream("/usr/local/azkaban/t3test.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
- 生成class文件
- jar -cvf AzkabanTest.jar AzkabanTest.class
- 移动到linux内
- 试运行
java -jar AzkabanTest.jar
3.编写job
- vim java.job
type=javaprocess
java.class=AzkabanTest
classpath=/usr/local/azkaban/jobs/t3/jar/*
4.将job打成zip
- zip java.zip java.job
5.web操作
HDFS操作任务
1.创建job描述文件
- vim fs.job
type=command
command=/usr/local/hadoop-2.7.1/bin/hadoop fs -mkdir /azkaban
2.将job资源文件打包成zip文件
zip fs.zip fs.job
3.web操作
MapReduce任务
1.创建job描述文件
- vim mapreduce.job
#mapreduce job
type=command
command=/usr/local/hadoop-2.7.1/bin/hadoop jar /usr/local/hadoop-2.7.1/share/hadoop/mapreduce/hadoop-mapreduce-examples-2.7.1.jar wordcount /wordcountinput /wordcountinputazkaban
2.将job资源文件打包成zip文件
zip mapreduce.zip mapreduce.job
3.web操作
边栏推荐
- Talk about the things that must be paid attention to when interviewing programmers
- Visual studio 2019 set transparent background (fool teaching)
- openresty ngx_lua变量操作
- Grpc message sending of vertx
- 丸子百度小程序详细配置教程,审核通过。
- Design and implementation of community hospital information system
- 2022/02/13
- Design of KTV intelligent dimming system based on MCU
- Pgadmin 4 V6.5 release, PostgreSQL open source graphical management tool
- Tucson will lose more than $400million in the next year
猜你喜欢
Spoon inserts and updates the Oracle database, and some prompts are inserted with errors. Assertion botch: negative time
Design and implementation of high availability website architecture
How to make a cool ink screen electronic clock?
【LeetCode】501. Mode in binary search tree (2 wrong questions)
Write a thread pool by hand, and take you to learn the implementation principle of ThreadPoolExecutor thread pool
Yolov5 model training and detection
Unpool(nn.MaxUnpool2d)
Yuan universe also "real estate"? Multiple second-hand trading websites block metauniverse keywords
Day_ 17 IO stream file class
Moco V2 literature research [self supervised learning]
随机推荐
Design and practice of kubernetes cluster and application monitoring scheme
Design and implementation of kindergarten management system
【LeetCode】106. Construct binary tree from middle order and post order traversal sequence (wrong question 2)
LeetCode 314. Binary tree vertical order traversal - Binary Tree Series Question 6
Acwing game 58 [End]
Kotlin - 协程 Coroutine
Open source SPL optimized report application coping endlessly
[daily problem insight] Li Kou - the 280th weekly match (I really didn't know it could be so simple to solve other people's problems)
Comparison of advantages and disadvantages between platform entry and independent deployment
"C zero foundation introduction hundred knowledge and hundred cases" (72) multi wave entrustment -- Mom shouted for dinner
D3js notes
ELFK部署
A label colorful navigation bar
打破信息茧房-我主动获取信息的方法 -#3
Bert fine tuning skills experiment
Can you really learn 3DMAX modeling by self-study?
Limited query of common SQL operations
openresty ngx_lua变量操作
PHP cli getting input from user and then dumping into variable possible?
【LeetCode】222. The number of nodes of a complete binary tree (2 mistakes)