azkaban的使用教程

这篇文章主要介绍“azkaban的使用教程”,在日常操作中,相信很多人在azkaban的使用教程问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”azkaban的使用教程”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

这篇文章主要介绍“azkaban的使用教程”,在日常操作中,相信很多人在azkaban的使用教程问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”azkaban的使用教程”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

登录
https://localhost:8443

成都创新互联公司主营昌邑网站建设的网络公司,主营网站建设方案,重庆App定制开发,昌邑h5微信平台小程序开发搭建,昌邑网站营销推广欢迎昌邑等地区企业咨询

注意是https,采用的是jetty ssl链接。输入账号密码azkaban/azkanban(如果你之前没有更改的话)

首页有四个菜单

projects:最重要的部分,创建一个工程,所有flows将在工程中运行。

scheduling:显示定时任务

executing:显示当前运行的任务

history:显示历史运行任务
主要介绍projects部分

首先创建一个工程,填写名称和描述,比如o2olog。

type=commandcommand=echo "data 2 hive"

一个简单的job就创建好了,解释下,type的command,告诉azkaban用unix原生命令去运行,比如原生命令或者shell脚本,当然也有其他类型,后面说。

一个工程不可能只有一个job,我们现在创建多个依赖job,这也是采用azkaban的首要目的。

flows创建
我们说过多个jobs和它们的依赖组成flow。怎么创建依赖,只要指定dependencies参数就行了。比如导入hive前,需要进行数据清洗,数据清洗前需要上传,上传之前需要从ftp获取日志。

定义5个job:

o2o_2_hive.job:将清洗完的数据入hive库

o2o_clean_data.job:调用mr清洗hdfs数据

o2o_up_2_hdfs.job:将文件上传至hdfs

o2o_get_file_ftp1.job:从ftp1获取日志

o2o_get_file_fip2.job:从ftp2获取日志
依赖关系:

3依赖4和5,2依赖3,1依赖2,4和5没有依赖关系。

o2o_2_hive.job

type=command# 执行sh脚本,建议这样做,后期只需维护脚本就行了,azkaban定义工作流程command=sh /job/o2o_2_hive.shdependencies=o2o_clean_data

o2o_clean_data.job

type=command# 执行sh脚本,建议这样做,后期只需维护脚本就行了,azkaban定义工作流程command=sh /job/o2o_clean_data.shdependencies=o2o_up_2_hdfs

o2o_up_2_hdfs.job

type=command#需要配置好hadoop命令,建议编写到shell中,可以后期维护command=hadoop fs -put /data/*#多个依赖用逗号隔开dependencies=o2o_get_file_ftp1,o2o_get_file_ftp2

o2o_get_file_ftp1.job

type=commandcommand=wget "ftp://file1" -O /data/file1

o2o_get_file_ftp2.job

type=commandcommand=wget "ftp:file2" -O /data/file2可以运行unix命令,也可以运行python脚本(强烈推荐)
。将上述job打成zip包。

ps:为了测试流程,我将上述command都改为echo +相应命令

上传:

点击o2o_2_hive进入流程,azkaban流程名称以最后一个没有依赖的job定义的。

右上方是配置执行当前流程或者执行定时流程。
Flow view:流程视图。可以禁用,启用某些job
Notification:定义任务成功或者失败是否发送邮件
Failure Options:定义一个job失败,剩下的job怎么执行
Concurrent:并行任务执行设置

Flow Parametters:参数设置。
1.执行一次

设置好上述参数,点击execute。

绿色代表成功,蓝色是运行,红色是失败。可以查看job运行时间,依赖和日志,点击details可以查看各个job运行情况。

我们可以点击Detail查看详细输出,以及报错。

2.定时执行

其他job配置选项

可以定义job依赖另一个flow,配置

type=flowflow.name=fisrt_flow

可以设置每个job中子命令

type=commandcommand=echo "hello"command.1=echo "world"

可以配置job失败重启次数,及间隔时间,比如,上述ftp获取日志,我可以配置重试12次,每隔5分钟一次。

type=commandcommand=wget "ftp://file1" -O /data/file1retries=12#单位毫秒retry.backoff=300000


新闻标题:azkaban的使用教程
标题路径:http://bzwzjz.com/article/ehdh.html

其他资讯

Copyright © 2007-2020 广东宝晨空调科技有限公司 All Rights Reserved 粤ICP备2022107769号
友情链接: 成都网站制作 网站建设公司 成都企业网站建设公司 成都网站设计 成都网站设计公司 企业网站设计 手机网站建设 成都网站制作 成都网站建设 成都网站设计 网站设计制作 成都网站建设 定制网站设计 手机网站制作 成都网站建设 企业网站建设 成都网站建设 网站建设方案 成都网站建设 四川成都网站制作 网站建设 手机网站制作