Azkaban的安装教程

news2024/12/29 17:22:06

Azkaban的安装教程


文章目录

  • Azkaban的安装教程
    • 写在前面
    • 集群模式安装
      • 下载安装包
      • 上传 **tar** 包
      • 解压
      • 配置 **MySQL**
      • 配置 **Executor Server**
        • 编辑 azkaban.properties
        • 同步 azkaban-exec到所有节点
        • 启动 executor server
        • 激活 executor
      • **配置** **Web Server**
        • 编辑 azkaban.properties
        • 修改 azkaban-users.xml文件
        • 启动 web server
        • 前端访问


写在前面

  • Linux版本:CentOS7.5
  • MySQL版本:MySQL5.7
  • Azkaban版本:Azkaban-3.84.4

集群模式安装

下载安装包

  • 下载地址:选择相对应的版本,下载azkaban-db、azkaban-exec-server、azkaban-web-server三个安装包

https://github.com/azkaban/azkaban/releases

上传 tar

  • 将下载的 azkaban-db-3.84.4.tar.gz,azkaban-exec-server-3.84.4.tar.gz,azkaban-web-server-3.84.4.tar.gz上传到 node01的/opt/software路径
[whybigdata@node01 software]$ ll  
总用量 35572  
-rw-r--r--. 1 whybigdata whybigdata  3.84.4.tar.gz  6433 118 17:24 azkaban-db-  
-rw-r--r--. 1 whybigdata whybigdata  16175002 118 17:26 azkaban-exec-server-3.84.4.tar.gz  
-rw-r--r--. 1 whybigdata whybigdata  20239974 118 17:26 azkaban-web-server-3.84.4.tar.gz  

解压

  • 新建/opt/module/azkaban-3.84.4目录,并将所有 tar包解压到这个目录下
[whybigdata@node01  software]$ mkdir /opt/module/azkaban-3.84.4 
  • 解压 azkaban-db-3.84.4.tar.gz、 azkaban-exec-server-3.84.4.tar.gz和 azkaban-web-server-3.84.4.tar.gz到/opt/module/azkaban目录下
[whybigdata@node01 software]$ tar -zxvf azkaban-db-3.84.4.tar.gz -C /opt/module/azkaban-3.84.4/  
[whybigdata@node01 software]$ tar -zxvf azkaban-exec-server-3.84.4.tar.gz -C /opt/module/azkaban-3.84.4/  
[whybigdata@node01 software]$ tar -zxvf azkaban-web-server-3.84.4.tar.gz -C /opt/module/azkaban-3.84.4/  
  • 进入到/opt/module/azkaban目录,依次修改名称
[whybigdata@node01 azkaban-3.84.4]$ mv azkaban-exec-server-3.84.4/ azkaban-exec  
[whybigdata@node01 azkaban-3.84.4]$ mv azkaban-web-server-3.84.4/ azkaban-web

配置 MySQL

  • 正常安装 MySQL

此处不演示

  • 启动 MySQL
[whybigdata@node01 azkaban-3.84.4]$ mysql -uroot –p123456  
  • 登陆 MySQL,创建 Azkaban数据库
mysql> create database azkaban;  
  • 创建 azkaban用户并赋予权限

设置密码有效长度 4位及以上

 mysql> set global validate_password_length=4;

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-rcn6Mra4-1676193310602)(1.png)]

注意:如果这里会报错的需要执行以下命令:

install plugin validate_password soname 'validate_password.so';  
  • 设置密码策略最低级别
mysql> set global validate_password_policy=0;          
  • 创建 Azkaban用户,任何主机都可以访问 Azkaban,密码是 123456
mysql> CREATE USER 'azkaban'@'%' IDENTIFIED BY '123456'; 
  • 赋予 Azkaban用户增删改查权限
mysql> GRANT SELECT,INSERT,UPDATE,DELETE ON azkaban.* to 'azkaban'@'%' WITH GRANT OPTION;
  • 创建 Azkaban表,完成后退出 MySQL
mysql> use azkaban;  
mysql> source /opt/module/azkaban/azkaban-db-3.84.4/create-all-sql-3.84.4.sql  
mysql> quit;
  • 更改 MySQL包大小:防止 Azkaban连接 MySQL阻塞
[whybigdata@node01 software]$ sudo vim /etc/my.cnf  

在[mysqld]下面加一行 max_allowed_packet=1024M

[mysqld] 
max_allowed_packet=1024M  
  • 重启 MySQL
[whybigdata@node01 software]$ sudo systemctl restart mysqld 

配置 Executor Server

Azkaban Executor Server处理工作流和作业的实际执行。

编辑 azkaban.properties

[whybigdata@node01 azkaban]$ vim /opt/module/azkaban-3.84.4/azkaban-exec/conf/azkaban.properties
  • 修改如下标红的属性
#...
default.timezone.id=Asia/Shanghai
#...
azkaban.webserver.url=http://node01:8081

executor.port=12321
#...
database.type=mysql
mysql.port=3306
mysql.host=node01
mysql.database=azkaban
mysql.user=azkaban
mysql.password=123456
mysql.numconnections=100

同步 azkaban-exec到所有节点

[whybigdata@node01 azkaban]$ xsync /opt/module/azkaban-3.84.4/azkaban-exec 

启动 executor server

注意:必须进入到/opt/module/azkaban-3.84.4/azkaban-exec路径,分别在三台机器上,启动 executor server

[whybigdata@node01 azkaban-exec]$ bin/start-exec.sh
[whybigdata@node02 azkaban-exec]$ bin/start-exec.sh
[whybigdata@node03 azkaban-exec]$ bin/start-exec.sh 

注意:如果在/opt/module/azkaban/azkaban-exec 目录下出现 executor.port 文件,说明启动成功

激活 executor

下面激活 executor,需要执行以下命令

[whybigdata@node01 azkaban-exec]$ curl -G "node01:12321/executor?action=activate"  && echo  
[whybigdata@node02 azkaban-exec]$ curl -G "node01:12321/executor?action=activate"  && echo 
[whybigdata@node03 azkaban-exec]$ curl -G "node01:12321/executor?action=activate"  && echo 

如果三台机器都出现如下提示,则表示激活成功

{"status":"success"}  

配置 Web Server

Azkaban Web Server处理项目管理,身份验证,计划和执行触发。

编辑 azkaban.properties

[whybigdata@node01 azkaban]$ vim /opt/module/azkaban-3.84.4/azkaban-web/conf/azkaban.properties
  • 修改如下属性
...
default.timezone.id=Asia/Shanghai
...
database.type=mysql
mysql.port=3306
mysql.host=node01
mysql.database=azkaban
mysql.user=azkaban
mysql.password=123456
mysql.numconnections=100
...
azkaban.executorselector.filters=StaticRemainingFlowSize,CpuStatus

解析说明:

  • #StaticRemainingFlowSize:正在排队的任务数;
  • #CpuStatus:CPU占用情况
  • #MinimumFreeMemory:内存占用情况。测试环境,必须将 MinimumFreeMemory删除掉,否则它会认为集群资源不够,不执行。

修改 azkaban-users.xml文件

修改 azkaban-users.xml文件,添加 whybigdata用户

[whybigdata@node01 azkaban-web]$ vim /opt/module/azkaban/azkaban-  web/conf/azkaban-users.xml  

<azkaban-users>  
  <user groups="azkaban" password="azkaban" roles="admin" username="azkaban"/>  
  <user password="metrics" roles="metrics" username="metrics"/>  
  <user password="123456" roles="admin" username="whybigdata"/> 
  <role name="admin" permissions="ADMIN"/>
  <role name="metrics" permissions="METRICS"/>
</azkaban-users>  

<user password="123456" roles="admin" username="whybigdata"/> 即为添加用户whybigdata

启动 web server

注意:必须进入到 node01的/opt/module/azkaban-3.84.4/azkaban-web路径,启动 web server

[whybigdata@node01 azkaban-web]$ bin/start-web.sh

前端访问

访问 http://node01:8081,并用 whybigdata用户登陆

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/682316.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

短视频seo源码搭建技术分享

一、目录及主要文件说明 bootstrap目录&#xff0c;存放框架引导及启动文件&#xff0c;非底层改动&#xff0c;无需修改。其中的functions.inc中可以定义一些全局函数error目录&#xff0c;存放404、500等常见错误模板文件&#xff0c;非需勿动includes目录&#xff0c;drupal…

SpringBoot 如何使用 JProfiler 进行性能测试

SpringBoot 如何使用 JProfiler 进行性能测试 在 SpringBoot 应用程序中&#xff0c;我们可以使用 JProfiler 进行性能测试。JProfiler 是一款专业的 Java 性能分析工具&#xff0c;可以帮助我们识别和解决应用程序的性能问题。使用 JProfiler 可以让我们更加准确地测试代码的…

C语言进阶教程(字符串深入)

文章目录 前言一、字符数组赋值注意事项二、混淆点三、字符串字面量和字符数组的区别四、字符串长度总结 前言 其实在C语言中是没有真正的字符串的&#xff0c;在C语言中字符串都是使用字符数组来完成的。 一、字符数组赋值注意事项 在C语言中&#xff0c;字符数组&#xff…

[RocketMQ] Producer生产者启动源码 (五)

DefaultMQProducer的关系图: 文章目录 1.创建DefaultMQProducer实例2.start启动生产者2.1 getOrCreateMQClientInstance获取或者创建MQClientInstance2.2 registerProducer注册生产者2.3 start启动MQClientInstance2.4 startScheduledTask启动各种定时任务2.4.1 updateTopicRou…

【Linux】切换内核版本(Centos)

1.查看服务器已安装的所有内核版本 awk -F\ $1"menuentry " {print i " : " $2} /etc/grub2.cfg0 : CentOS Linux (3.10.0-1160.83.1.el7.x86_64) 7 (Core) 1 : CentOS Linux (3.10.0-1160.80.1.el7.x86_64) 7 (Core) 2 : CentOS Linux (3.10.0-1127.el7.…

求最小函数依赖集(例题讲解)超详细,易理解

在关系R<U,F>中&#xff0c;UABCDEG F{BG->C&#xff0c;BD->E,DG->C,ADG->BC,AG->B,B->D} 先进行第一大步&#xff1a; 先看右边&#xff1a; 如果有BG->C,G-->C,因为单G就可以推出C了就不需要BG--->C了&#xff0c;可以把BG--->C这个…

Segment Anything Model(SAM)

Segment Anything Model&#xff08;SAM&#xff09;是Facebook Research近来开源的一种新的图像分割任务、模型。Segment Anything Model&#xff08;SAM&#xff09;可以从输入提示&#xff08;如点或框&#xff09;生成高质量的对象掩模&#xff0c;并可用于生成图像中所有对…

1、一条 SQL 查询语句是如何执行的?

基础篇 第一课、一条 SQL 查询语句是如何执行的&#xff1f; 下面是 MySQL 的基本架构示意图&#xff0c;从中可以清楚地看到 SQL 语句在 MySQL 的各个功能模块中的执行过程。 大体来说&#xff0c;MySQL 可以分为 Server 层和存储引擎层两部分。 Server 层包括连接器、查询缓存…

AI近十年盘点:纵览AI发展历程,探寻AI未来走向

编者按&#xff1a;当我们回顾过去十年的人工智能发展历程时&#xff0c;可以看到一场现在还正在进行的变革&#xff0c;对我们的工作方式、商业运营模式和人际交往行为都产生了深远的影响。从2013年的AlexNet到变分自编码器&#xff0c;再到最近的生成式大模型&#xff0c;人工…

Vue 2 - 常见面试题汇总大全

文章目录 一 基础知识1.vue 的生命周期1-1 钩子函数1-2 钩子函数的使用方法1-3 父子组件生命周期构造函数执行顺序 2 v-show 与 v-if v-for2-1.v-show 与 v-if 的区别2-2 v-if 和v-for的优先级 3.组件通信有哪些方式&#xff1f;4 computed和watch &#xff0c;有什么区别4-1.c…

西门子S7-1200定时器

一、西门子S7-1200定时器介绍 S7-1200的定时器为IEC定时器&#xff0c;用户程序中可以使用的定时器数量仅仅受CPU的存储器容量限制。 使用定时器需要使用定时器相关的背景数据块或者数据类型为IEC_TIMER&#xff08;或TP_TIME、TON_TIME、TOF_TIME、TONR_TIME&#xff09;的D…

别再弄混流程挖掘、BPM和BI

信息时代以来&#xff0c;各类信息系统不仅在企业中得到了广泛的应用和普及&#xff0c;种类和选择伴随全球数字技术的发展也逐渐变得丰富多样。而随着数字化转型的不断深入&#xff0c;企业对系统管理的需求面临着全新的变化。 如何配置最适合当下业务的系统&#xff1f;这个…

Axure教程——图片轮播(纵向滚动)

本文介绍的时用Axure中的动态面板制作图片轮播之纵向滚动 一、预览效果 预览地址&#xff1a;https://c1s4i1.axshare.com 二、功能描述 图片纵向自动滚动播放 三、元件制作 拖入一个动态面板&#xff0c;命名为1&#xff0c;设置大小为375*155&#xff0c;并设置四个状态&…

文科生从0学Python转数据分析学习建议避坑指南

我本科是财务管理&#xff0c;文科专业&#xff0c;零基础学习Python转行数分后&#xff0c;现在我的日常工作都离不开它。 接下来&#xff0c;给各位跟我一样无编程经验的朋友一些学习的建议 目标导向&#xff1a;先搞清楚为啥要学 Python几乎可以做任何事&#xff0c;但我…

2023汽车供应链大会暨爱普搜采购商交流会

2023汽车供应链大会暨爱普搜采购商交流会 Automotive Supply Chain Conference & APSOTO Purchasing Exchange Meeting 补链强链 绿色发展--打造中国汽车供应链新生态 北京是我国汽车工业重地之一&#xff0c;产业实力雄厚&#xff0c;发展强劲。北京车企及零部件公司分布…

springboot高校宿舍报修管理系统计算机毕设 附源码83946

springboot高校宿舍报修管理系统 摘 要 科技进步的飞速发展引起人们日常生活的巨大变化&#xff0c;电子信息技术的飞速发展使得电子信息技术的各个领域的应用水平得到普及和应用。信息时代的到来已成为不可阻挡的时尚潮流&#xff0c;人类发展的历史正进入一个新时代。在现实…

VUE L 事件处理 ⑤

目录 文章有误请指正&#xff0c;如果觉得对你有用&#xff0c;请点三连一波&#xff0c;蟹蟹支持✨ V u e j s Vuejs Vuejs E v e n t j s Eventjs Eventjs总结 文章有误请指正&#xff0c;如果觉得对你有用&#xff0c;请点三连一波&#xff0c;蟹蟹支持✨ ⡖⠒⠒⠒⠤⢄⠀⠀⠀…

Java反射机制以及应用

Java反射机制以及应用 1、Java反射 在运行状态中&#xff0c;对于任意一个类&#xff0c;都能够获取到这个类的所有属性和方法&#xff0c;对于任意一个对象&#xff0c;都能够调用它的任意一个方法和属性(包括私有的方法和属性)&#xff0c;这种动态获取的信息以及动态调用对…

【推荐】免费PDF编辑修改软件排行榜Top11!

随着组织进入数字时代&#xff0c;他们需要处理大量数字文档&#xff0c;尤其是 PDF。PDF 是数字文档中使用最广泛的文件格式之一&#xff0c;能够编辑 PDF 文件至关重要。PDF编辑并不是任何软件都能轻松完成的。不过&#xff0c;网络上有大量免费、开源的 PDF 编辑软件可以帮助…

基于Springboot+vue+协同过滤+前后端分离+电子产品推荐系统(用户,多商户,管理员)+全套视频教程

基于Springbootvue协同过滤前后端分离电子产品推荐系统(用户,多商户,管理员)(毕业论文11000字以上,共33页,程序代码,MySQL数据库) 代码下载 链接&#xff1a;https://pan.baidu.com/s/1ckCKm4zKT0m4RqfHULYyOg 提取码&#xff1a;8888 【运行环境】Idea JDK1.8 Maven MySQL …