大數據軟件安裝之Azkaban（任務調度）

1、安裝部署

一、安裝前準備

1）下載地址:http://azkaban.github.io/downloads.html

2）將Azkaban Web服務器、Azkaban執行服務器、Azkaban的sql執行腳本及MySQL安裝包拷貝到hadoop102機器的/opt/software目錄下

　　azkaban-web-server-2.5.0.tar.gz

　　azkaban-executor-server-2.5.0.tar.gz

　　azkaban-sql-script-2.5.0.tar.gz

3）選擇Mysql做爲Azkaban數據庫，由於Azkaban創建了一些Mysql鏈接加強功能，以方便Azkaban設置，並加強服務可靠性。

二、安裝Azkaban

1）在/opt/module/目錄下建立azkaban目錄

[test@hadoop102 module]$ mkdir azkaban

2）解壓

　　azkaban-web-server-2.5.0.tar.gz、

　　azkaban-executor-server-2.5.0.tar.gz、

　　azkaban-sql-script-2.5.0.tar.gz到/opt/module/azkaban目錄下

[test@hadoop102 software]$ tar -zxvf azkaban-web-server-2.5.0.tar.gz -C /opt/module/azkaban/

[test@hadoop102 software]$ tar -zxvf azkaban-executor-server-2.5.0.tar.gz -C /opt/module/azkaban/

[test@hadoop102 software]$ tar -zxvf azkaban-sql-script-2.5.0.tar.gz -C /opt/module/azkaban/

3）對解壓後的文件從新命名

[test@hadoop102 azkaban]$ mv azkaban-web-2.5.0/ server

[test@hadoop102 azkaban]$ mv azkaban-executor-2.5.0/ executor

4）azkaban腳本導入

進入mysql，建立azkaban數據庫，並將解壓的腳本導入到azkaban數據庫。

[test@hadoop102 azkaban]$ mysql -uroot -p000000

mysql> create database azkaban;

mysql> use azkaban;

mysql> source /opt/module/azkaban/azkaban-2.5.0/create-all-sql-2.5.0.sql;

注：source後跟.sql文件，用於批量處理.sql文件中的sql語句。

三、生成密鑰庫

Keytool是java數據證書的管理工具，使用戶可以管理本身的公/私鑰對及相關證書。

-keystore    指定密鑰庫的名稱及位置(產生的各種信息將不在.keystore文件中)

-genkey      在用戶主目錄中建立一個默認文件".keystore"

-alias  對咱們生成的.keystore 進行指認別名；若是沒有默認是mykey

-keyalg  指定密鑰的算法 RSA/DSA 默認是DSA

1）生成 keystore的密碼及相應信息的密鑰庫

[test@hadoop102 azkaban]$ keytool -keystore keystore -alias jetty -genkey -keyalg RSA

輸入密鑰庫口令: 

再次輸入新口令:

您的名字與姓氏是什麼?

  [Unknown]: 

您的組織單位名稱是什麼?

  [Unknown]: 

您的組織名稱是什麼?

  [Unknown]: 

您所在的城市或區域名稱是什麼?

  [Unknown]: 

您所在的省/市/自治區名稱是什麼?

  [Unknown]: 

該單位的雙字母國家/地區代碼是什麼?

  [Unknown]: 

CN=Unknown, OU=Unknown, O=Unknown, L=Unknown, ST=Unknown, C=Unknown是否正確?

  [否]:  y

 

輸入 <jetty> 的密鑰口令

        (若是和密鑰庫口令相同, 按回車): 

再次輸入新口令:

注意：

密鑰庫的密碼至少必須6個字符，能夠是純數字或者字母或者數字和字母的組合等等

密鑰庫的密碼最好和<jetty> 的密鑰相同，方便記憶

2）將keystore 拷貝到 azkaban web服務器根目錄中

[test@hadoop102 azkaban]$ mv keystore /opt/module/azkaban/server/

四、時間同步配置

先配置好服務器節點上的時區

1）若是在/usr/share/zoneinfo/這個目錄下不存在時區配置文件Asia/Shanghai，就要用 tzselect 生成。

[test@hadoop102 azkaban]$ tzselect

Please identify a location so that time zone rules can be set correctly.

Please select a continent or ocean.

 1) Africa

 2) Americas

 3) Antarctica

 4) Arctic Ocean

 5) Asia

 6) Atlantic Ocean

 7) Australia

 8) Europe

 9) Indian Ocean

10) Pacific Ocean

11) none - I want to specify the time zone using the Posix TZ format.

#? 5

Please select a country.

 1) Afghanistan           18) Israel                35) Palestine

 2) Armenia               19) Japan                 36) Philippines

 3) Azerbaijan            20) Jordan                37) Qatar

 4) Bahrain               21) Kazakhstan            38) Russia

 5) Bangladesh            22) Korea (North)         39) Saudi Arabia

 6) Bhutan                23) Korea (South)         40) Singapore

 7) Brunei                24) Kuwait                41) Sri Lanka

 8) Cambodia              25) Kyrgyzstan            42) Syria

 9) China                 26) Laos                  43) Taiwan

10) Cyprus                27) Lebanon               44) Tajikistan

11) East Timor            28) Macau                 45) Thailand

12) Georgia               29) Malaysia              46) Turkmenistan

13) Hong Kong             30) Mongolia              47) United Arab Emirates

14) India                 31) Myanmar (Burma)       48) Uzbekistan

15) Indonesia             32) Nepal                 49) Vietnam

16) Iran                  33) Oman                  50) Yemen

17) Iraq                  34) Pakistan

#? 9

Please select one of the following time zone regions.

1) Beijing Time

2) Xinjiang Time

#? 1

 

The following information has been given:

 

        China

        Beijing Time

 

Therefore TZ='Asia/Shanghai' will be used.

Local time is now:      Thu Oct 18 16:24:23 CST 2018.

Universal Time is now:  Thu Oct 18 08:24:23 UTC 2018.

Is the above information OK?

1) Yes

2) No

#? 1

 

You can make this change permanent for yourself by appending the line

        TZ='Asia/Shanghai'; export TZ

to the file '.profile' in your home directory; then log out and log in again.

 

Here is that TZ value again, this time on standard output so that you

can use the /usr/bin/tzselect command in shell scripts:

Asia/Shanghai

2）拷貝該時區文件，覆蓋系統本地時區配置

[test@hadoop102 azkaban]$ cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime

2、配置文件

一、web服務器配置

1）進入azkaban web 服務器的安裝目錄 conf ，打開azkaban.properties文件

[test@hadoop102 conf]$ pwd

/opt/module/azkaban/server/conf

[test@hadoop102 conf]$ vim azkaban.properties

按照以下配置修改azkaban.properties文件

#Azkaban Personalization Settings

#服務器UI名稱,用於服務器上方顯示的名字

azkaban.name=Test

#描述

azkaban.label=My Local Azkaban

#UI顏色

azkaban.color=#FF3601

azkaban.default.servlet.path=/index

#默認web server存放web文件的目錄

web.resource.dir=/opt/module/azkaban/server/web/

#默認時區,已改成亞洲/上海 默認爲美國

default.timezone.id=Asia/Shanghai

 

#Azkaban UserManager class

user.manager.class=azkaban.user.XmlUserManager

#用戶權限管理默認類（絕對路徑）

user.manager.xml.file=/opt/module/azkaban/server/conf/azkaban-users.xml

 

#Loader for projects

#global配置文件所在位置（絕對路徑）

executor.global.properties=/opt/module/azkaban/executor/conf/global.properties

azkaban.project.dir=projects

 

#數據庫類型

database.type=mysql

#端口號

mysql.port=3306

#數據庫鏈接IP

mysql.host=hadoop102

#數據庫實例名

mysql.database=azkaban

#數據庫用戶名

mysql.user=root

#數據庫密碼

mysql.password=000000

#最大鏈接數

mysql.numconnections=100

 

# Velocity dev mode

velocity.dev.mode=false

 

# Azkaban Jetty server properties

# Jetty服務器屬性

#最大線程數

jetty.maxThreads=25

#Jetty SSL端口

jetty.ssl.port=8443

#Jetty端口

jetty.port=8081

#SSL文件名（絕對路徑）

jetty.keystore=/opt/module/azkaban/server/keystore

#SSL文件密碼

jetty.password=000000

#Jetty主密碼與keystore文件相同

jetty.keypassword=000000

#SSL文件名（絕對路徑）

jetty.truststore=/opt/module/azkaban/server/keystore

#SSL文件密碼

jetty.trustpassword=000000

 

# Azkaban Executor settings

executor.port=12321

 

# mail settings

mail.sender=

mail.host=

job.failure.email=

job.success.email=

 

lockdown.create.projects=false

 

cache.directory=cache

2）web服務器用戶配置

在azkaban web服務器安裝目錄 conf目錄，按照以下配置修改azkaban-users.xml 文件，增長管理員用戶。

[test@hadoop102 conf]$ vim azkaban-users.xml

<azkaban-users>

    <user username="azkaban" password="azkaban" roles="admin" groups="azkaban" />

    <user username="metrics" password="metrics" roles="metrics"/>

    <user username="admin" password="admin" roles="admin,metrics"/>

    <role name="admin" permissions="ADMIN" />

    <role name="metrics" permissions="METRICS"/>

</azkaban-users>

二、執行服務器配置

1）進入執行服務器安裝目錄conf，打開azkaban.properties

[test@hadoop102 conf]$ pwd

/opt/module/azkaban/executor/conf

[test@hadoop102 conf]$ vim azkaban.properties

2）按照以下配置修改azkaban.properties文件

#Azkaban

#時區

default.timezone.id=Asia/Shanghai

 

# Azkaban JobTypes Plugins

#jobtype 插件所在位置

azkaban.jobtype.plugin.dir=plugins/jobtypes

 

#Loader for projects

executor.global.properties=/opt/module/azkaban/executor/conf/global.properties

azkaban.project.dir=projects

 

database.type=mysql

mysql.port=3306

mysql.host=hadoop102

mysql.database=azkaban

mysql.user=root

mysql.password=000000

mysql.numconnections=100

 

# Azkaban Executor settings

#最大線程數

executor.maxThreads=50

#端口號(如修改,請與web服務中一致)

executor.port=12321

#線程數

executor.flow.threads=30

3、啓動訪問Azkaban  web頁面

一、啓動executor服務器

在executor服務器目錄下執行啓動命令

[test@hadoop102 executor]$ pwd

/opt/module/azkaban/executor

[test@hadoop102 executor]$ bin/azkaban-executor-start.sh

二、啓動web服務器

在azkaban web服務器目錄下執行啓動命令

[test@hadoop102 server]$ pwd

/opt/module/azkaban/server

[test@hadoop102 server]$ bin/azkaban-web-start.sh

注意：

先執行executor，再執行web，避免Web Server會由於找不到執行器啓動失敗。

jps查看進程

[test@hadoop102 server]$ jps

3601 AzkabanExecutorServer

5880 Jps

3661 AzkabanWebServer

啓動完成後，在瀏覽器(建議使用谷歌瀏覽器)中輸入https://服務器IP地址:8443，便可訪問azkaban服務了。

在登陸中輸入剛纔在azkaban-users.xml文件中新添加的戶用名及密碼，點擊 login。