Sqoop是一款開源的工具,主要用于在Hadoop(Hive)與傳統(tǒng)的數(shù)據(jù)庫(mysql、postgresql...)間進(jìn)行數(shù)據(jù)的傳遞,可以將一個關(guān)系型數(shù)據(jù)庫(例如 : MySQL ,Oracle ,Postgres等)中的數(shù)據(jù)導(dǎo)進(jìn)到Hadoop的HDFS中,也可以將HDFS的數(shù)據(jù)導(dǎo)進(jìn)到關(guān)系型數(shù)據(jù)庫中。Sqoop項目開始于2009年,最早是作為Hadoop的一個第三方模塊存在,后來為了讓使用者能夠快速部署,也為了讓開發(fā)人員能夠更快速的迭代開發(fā),Sqoop獨(dú)立成為一個Apache項目。
總之Sqoop是一個轉(zhuǎn)換工具,用于在關(guān)系型數(shù)據(jù)庫與HDFS之間進(jìn)行數(shù)據(jù)轉(zhuǎn)換。
注意:sqoop1與sqoop2完全不兼容,1.4.6及之前的版本是sqoop1,之后的是sqoop2
Sqoop1和Sqoop2的對比
sqoop2比sqoop1的改進(jìn)
引入sqoop server,集中化管理connector等
多種訪問方式:CLI,Web UI,REST API
引入基于角色 的安全機(jī)制
sqoop1與sqoop2的優(yōu)缺點
sqoop1的架構(gòu),僅僅使用一個sqoop客戶端,sqoop2的架構(gòu),引入了sqoop server集中化管理connector,以及rest api,web,UI,并引入權(quán)限安全機(jī)制。
sqoop1優(yōu)點架構(gòu)部署簡單
sqoop1的缺點命令行方式容易出錯,格式緊耦合,無法支持所有數(shù)據(jù)類型,安全機(jī)制不夠完善,例如密碼暴漏,
安裝需要root權(quán)限,connector必須符合JDBC模型
sqoop2的優(yōu)點多種交互方式,命令行,web UI,rest API,conncetor集中化管理,所有的鏈接安裝在sqoop server上,完善權(quán)限管理機(jī)制,connector規(guī)范化,僅僅負(fù)責(zé)數(shù)據(jù)的讀寫。
sqoop2的缺點,架構(gòu)稍復(fù)雜,配置部署更繁瑣。
sqoop1架構(gòu)圖
sqoop2架構(gòu)圖
由于sqoop2還不是很完善,官方建議生產(chǎn)環(huán)境不建議使用,在此就sqoop1.4.6來作介紹
安裝環(huán)境:
Cenos7系統(tǒng)
sqoop版本:1.4.6
Hadoop:2.7.3
MySQL:5.7.15
JDK :1.8
下載并解壓sqoop1.4.6
安裝在一臺節(jié)點上就可以了
點擊 sqoop 下載地址,下載Sqoop安裝文件sqoop-1.4.6.bin__hadoop-2.0.4-alpha.tar.gz。將文件上傳到服務(wù)器的/usr/local文件夾中。
下面執(zhí)行以下命令
1. cd ~ #進(jìn)入當(dāng)前用戶的用戶目錄2. cd /usr/local3. sudo tar -zxvf sqoop-1.4.6.bin__hadoop-2.0.4-alpha.tar.gz -C /usr/local #解壓安裝文件5. sudo mv sqoop-1.4.6.bin__hadoop-2.0.4-alpha sqoop146 #修改文件名6. sudo chown -R hadoop:hadoop sqoop146 #修改文件夾屬主,如果你當(dāng)前登錄用戶名不是hadoop,請修改成你自己的用戶名 (hadoop為用Hadoop創(chuàng)建的用戶組和用戶名,sqoop將與Hadoop組合使用)
修改配置文件sqoop-env.sh
1. cd sqoop146/conf/ 2. cat sqoop-env-template.sh >> sqoop-env.sh #將sqoop-env-template.sh復(fù)制一份并命名為sqoop-env.sh3. vi sqoop-env.sh #編輯sqoop-env.sh
修改sqoop-env.sh的如下信息,若有其它的可以都加上
export HADOOP_COMMON_HOME=/usr/local/hadoop273 export HADOOP_MAPRED_HOME=/usr/local/hadoop273
export HBASE_HOME=/usr/local/hbase
export HIVE_HOME=/usr/local/hive
export ZOOCFGDIR= #如果讀者配置了ZooKeeper,也需要在此配置ZooKeeper的路徑
配置環(huán)境變量
打開當(dāng)前用戶的環(huán)境變量配置文件:
vi ~/.bash_profile
在配置文件第一行鍵入如下信息:
export SQOOP_HOME=/usr/local/sqoop146 export PATH=$PATH:$SBT_HOME/bin:$SQOOP_HOME/bin export CLASSPATH=$CLASSPATH:$SQOOP_HOME/lib
保存該文件,退出vim編輯器。
然后,執(zhí)行下面命令讓配置文件立即生效:
source ~/.bash_profile
將mysql驅(qū)動包拷貝到$SQOOP_HOME/lib
下面要把MySQL驅(qū)動程序和hadoop-connector jar包拷貝到$SQOOP_HOME/lib目錄下,不存在先下載驅(qū)動包。
cp ./mysql-connector-java-5.1.40/mysql-connector-java-5.1.40-bin.jar /usr/local/sqoop146/lib cp $HADOOP_HOME/share/hadoop/common/hadoop-common-2.7.3.jar $SQOOP_HOME/lib
修改$SQOOP_HOME/bin/configure-sqoop
注釋掉HCatalog,Accumulo檢查(除非你準(zhǔn)備使用HCatalog,Accumulo等HADOOP上的組件)
##Moved to be a runtime check in sqoop.#if[ ! -d "${HCAT_HOME}" ]; then# echo "Warning: $HCAT_HOME does notexist! HCatalog jobs will fail."# echo 'Please set $HCAT_HOME to the root ofyour HCatalog installation.'#fi #if[ ! -d "${ACCUMULO_HOME}" ]; then# echo "Warning: $ACCUMULO_HOME does notexist! Accumulo imports will fail."# echo 'Please set $ACCUMULO_HOME to the rootof your Accumulo installation.'#fi #Add HCatalog to dependency list#if[ -e "${HCAT_HOME}/bin/hcat" ]; then# TMP_SQOOP_CLASSPATH=${SQOOP_CLASSPATH}:`${HCAT_HOME}/bin/hcat-classpath`# if [ -z "${HIVE_CONF_DIR}" ]; then# TMP_SQOOP_CLASSPATH=${TMP_SQOOP_CLASSPATH}:${HIVE_CONF_DIR}# fi# SQOOP_CLASSPATH=${TMP_SQOOP_CLASSPATH}#fi #Add Accumulo to dependency list#if[ -e "$ACCUMULO_HOME/bin/accumulo" ]; then# for jn in `$ACCUMULO_HOME/bin/accumuloclasspath | grep file:.*accumulo.*jar |cut -d':' -f2`; do# SQOOP_CLASSPATH=$SQOOP_CLASSPATH:$jn# done# for jn in `$ACCUMULO_HOME/bin/accumuloclasspath | grep file:.*zookeeper.*jar |cut -d':' -f2`; do# SQOOP_CLASSPATH=$SQOOP_CLASSPATH:$jn# done#fi
測試與MySQL的連接
首先請確保mysql服務(wù)已經(jīng)啟動了,如果沒有啟動,請執(zhí)行下面命令啟動:
service mysql start
然后就可以測試sqoop與MySQL之間的連接是否成功:
sqoop list-databases --connect jdbc:mysql://127.0.0.1:3306/ --username root -password root
root為數(shù)據(jù)庫的用戶名和密碼,mysql的數(shù)據(jù)庫列表顯示在屏幕上表示連接成功。
作者:歡醉
公眾號【一個碼農(nóng)的日?!?1號群: 437802986 2號群: 340250479
出處:http://zhangs1986.cnblogs.com/
本文版權(quán)歸作者和博客園共有,歡迎轉(zhuǎn)載,但未經(jīng)作者同意必須保留此段聲明,且在文章頁面明顯位置給出原文連接,否則保留追究法律責(zé)任的權(quán)利。
http://www.cnblogs.com/zhangs1986/p/7052621.html