当前位置: 首页 > news >正文

Azkaban 大数据 任务调度

参考视频:尚硅谷大数据Azkaban 3.x教程(全新发布)_哔哩哔哩_bilibili

Azkaban: 是一个定时、批量工作流任务调度器(工作流程调度,定时调度)

常见的开源调度系统:

        简单单一的任务调度: Linux的Crontab

        复杂的任务调度: Ooize ,Azkaban, Airflow(python写的), DolphinScheduler

 比较:

        Ooize 相比Azkaban 是一个重量级的任务调度系统,功能全面,但配置使用更加复杂。如果可以不在意某些功能的缺失,轻量级调度器Azkaban是很不错的选择

        Ooize : CDH平台下的平台调度器,借助可视化的HUE使用比较友好

        Azkaban:简单易用

        Airflow : python开发调度的,具备一定的python基础

        DolphinScheduler: 现在比较好的,可视化的操作,比较方便

特点:

    1 兼容任何版本的hadoop

    2 易于使用的web用户界面

    3 简单的工作流上传

    4 方便设置任务之间的关系

    5 调度工作流

    6 模块化和可插拔的插件机制

    7 认证/授权

    8 能够杀死并重新启动工作流

    9 有关失败和成功的电子邮件提醒

三个关键组件

  1  AzkabanWebServer :

        是Azkaban工作流系统的主要管理者,作用:用户认证,负责project管理,定时执行工作流,跟踪工作流执行进度等等

  2  AzkabanExecutorServer :

        负责具体的工作流的提交、执行,他们通过mysql数据库来协调任务的执行

  3  Mysql :

        存储大部分执行流状态等信息

部署:

       1 上传jar包,解压

                里面mysql脚本包,excecutor包(集群部署多个服务器),web包.

                安装顺序: mysql -> excecutor -> web

        2 安装mysql数据库

                刷mysql脚本里的 create-all-sql-3.xxxx.sql 脚本

        3 修改mysql的配置文件                
sudo vim /etc/my.cnf# mysqld下面加一行 , 更改mysql包大小,防止Azkaban连接Mysql阻塞,重启mysql
max_allowed_packet=1024M# 重启mysql
sudo systemctl restart mysqld
        4 配置Executor Server

                编辑executor解压包下conf里的 azkaban.properties , 同步其他节点

vim .../azkaban/azkaban-exec/conf/azkaban.properties# 配置时区
default.timezone.id=Asia/Shanghai# webserver的连接 
azkaban.webserver.url=http://hadoop102:8081# executor的端口,不配会随机值,不便于管理
executor.port=12321# 配置数据库信息
mysql.port=3306
mysql.host=
mysql.database=
mysql.user=
mysql.password=
         5 Executor Server启动,激活:         
# 最好进入azkaban/azkaban-exec下执行,启动server
# 如果 azkaban-exec 下面出现executor.port文件,说明启动成功。或者数据库表(executors)里查看
bin/start-exec.sh# 激活
curl -G "hadoop102:12321/executor?action=activate" && echojps 查看
        6 配置 Web Server 

        编辑 web解压包下conf的azkaban.properties        

default.timezone.id=Asia/Shanghai#mysql的数据库信息
mysql...# 集群可不做修改,单机MininumFreeMemory可能保留的内存过多导致无法启动,去掉
# StaticRemainingFlowSize 正在排队的任务数
# MininumFreeMemory 内存占用最小保留
# CpuStatus cpu占用情况
azkaban.executorselector.filters=StaticRemainingFlowSize,MininumFreeMemory,CpuStatus
        7 修改azkaban-users.xml文件 ,用于用户管理

        可以不配,默认是 azkaban azkaban

vim .../azkaban/azkaban-web/conf/azkaban-users.xml<user password="123456" roles="admin" username="atguigu">
        8 启动web server
bin/start-web.sh

        访问: http://hadoop:8081(/index)  ,并用atguigu登录

Azkaban内置的任务类型支持:commond,java

相关文章:

  • 认识通讯协议——TCP/IP、UDP协议的区别,HTTP通讯协议的理解
  • 【洛谷 P8682】[蓝桥杯 2019 省 B] 等差数列 题解(数学+排序+辗转相除法)
  • 750541-89-0,mPEG4 phosphonic acid,可以作为催化剂、络合剂
  • spring、springmvc、springboot框架的介绍
  • NOIP 2009普及组初赛试题及解析
  • RunnerGo UI自动化测试脚本如何配置
  • 了解游戏中的数据同步
  • java框架八股
  • Node.js中的并发和多线程处理
  • Java毕业设计 基于SpringBoot vue 社团管理系统
  • 【wpf】关于绑定的一点明悟
  • http 协议深入介绍
  • 在vue前端开发中基于refreshToken和axios拦截器实现token的无感刷新
  • sql 分割字段,并分行
  • python数据分析numpy基础之cumsum求数组累计和
  • [ 一起学React系列 -- 8 ] React中的文件上传
  • DOM的那些事
  • ES2017异步函数现已正式可用
  • LeetCode29.两数相除 JavaScript
  • Python利用正则抓取网页内容保存到本地
  • rabbitmq延迟消息示例
  • STAR法则
  • ViewService——一种保证客户端与服务端同步的方法
  • 前端自动化解决方案
  • 手机app有了短信验证码还有没必要有图片验证码?
  • 微信开源mars源码分析1—上层samples分析
  • 要让cordova项目适配iphoneX + ios11.4,总共要几步?三步
  • 再次简单明了总结flex布局,一看就懂...
  • 在electron中实现跨域请求,无需更改服务器端设置
  • Spark2.4.0源码分析之WorldCount 默认shuffling并行度为200(九) ...
  • 支付宝花15年解决的这个问题,顶得上做出十个支付宝 ...
  • ​sqlite3 --- SQLite 数据库 DB-API 2.0 接口模块​
  • ​一、什么是射频识别?二、射频识别系统组成及工作原理三、射频识别系统分类四、RFID与物联网​
  • #pragma data_seg 共享数据区(转)
  • (7)STL算法之交换赋值
  • (二)斐波那契Fabonacci函数
  • (分布式缓存)Redis哨兵
  • (论文阅读笔记)Network planning with deep reinforcement learning
  • (转)Unity3DUnity3D在android下调试
  • (转)可以带来幸福的一本书
  • ../depcomp: line 571: exec: g++: not found
  • .class文件转换.java_从一个class文件深入理解Java字节码结构
  • .NET 8.0 中有哪些新的变化?
  • .NET 依赖注入和配置系统
  • .net程序集学习心得
  • .net流程开发平台的一些难点(1)
  • :“Failed to access IIS metabase”解决方法
  • [ MSF使用实例 ] 利用永恒之蓝(MS17-010)漏洞导致windows靶机蓝屏并获取靶机权限
  • [20180224]expdp query 写法问题.txt
  • [bzoj1901]: Zju2112 Dynamic Rankings
  • [CVPR 2023:3D Gaussian Splatting:实时的神经场渲染]
  • [EFI]Acer Aspire A515-54g电脑 Hackintosh 黑苹果efi引导文件
  • [ESP32 IDF]web server
  • [flask]http请求//获取请求体数据
  • [Kubernetes]9. K8s ingress讲解借助ingress配置http,https访问k8s集群应用