首页 > 其他 > 详细

Hbase基础(七):Sqoop 的简单使用案例

时间:2020-07-31 15:46:07      阅读:95      评论:0      收藏:0      [点我收藏+]

1 导入数据

在 Sqoop 中,“导入”概念指:从非大数据集群(RDBMS)向大数据集群(HDFS,HIVE,HBASE)中传输数据,叫做:导入,即使用 import 关键字。
1.1 RDBMS 到 HDFS
1) 确定 Mysql 服务开启正常
2) 在 Mysql 中新建一张表并插入一些数据
$ mysql -uroot -p000000
mysql> create database company;
mysql> create table company.staff(id int(4) primary key not null 
auto_increment, name varchar(255), sex varchar(255));
mysql> insert into company.staff(name, sex) values(‘Thomas‘, ‘Male‘);
mysql> insert into company.staff(name, sex) values(‘Catalina‘, 
‘FeMale‘);
3) 导入数据
(1)全部导入
$ bin/sqoop import --connect jdbc:mysql://hadoop102:3306/company \
--username root --password 000000 --table staff --target-dir /user/company --delete-target-dir --num-mappers 1 --fields-terminated-by "\t"
(2)查询导入
$ bin/sqoop import --connect jdbc:mysql://hadoop102:3306/company \
--username root --password 000000 --target-dir /user/company --delete-target-dir --num-mappers 1 --fields-terminated-by "\t" --query ‘select name,sex from staff where id <=1 and $CONDITIONS;‘
提示:must contain ‘$CONDITIONS‘ in WHERE clause.
如果 query 后使用的是双引号,则$CONDITIONS 前必须加转移符,防止 shell 识别为自己的变量。
(3)导入指定列
$ bin/sqoop import --connect jdbc:mysql://hadoop102:3306/company \
--username root --password 000000 --target-dir /user/company --delete-target-dir --num-mappers 1 --fields-terminated-by "\t" --columns id,sex --table staff
提示:columns 中如果涉及到多列,用逗号分隔,分隔时不要添加空格
(4)使用 sqoop 关键字筛选查询导入数据
$ bin/sqoop import --connect jdbc:mysql://hadoop102:3306/company \
--username root --password 000000 --target-dir /user/company --delete-target-dir --num-mappers 1 --fields-terminated-by "\t" --table staff --where "id=1"
1.2 RDBMS 到 Hive
$ bin/sqoop import --connect jdbc:mysql://hadoop102:3306/company \
--username root --password 000000 --table staff --num-mappers 1 --hive-import --fields-terminated-by "\t" --hive-overwrite --hive-table staff_hive
提示:该过程分为两步,第一步将数据导入到 HDFS,第二步将导入到 HDFS 的数据迁移到
Hive 仓库,第一步默认的临时目录是/user/atguigu/表名
1.3 RDBMS 到 Hbase
$ bin/sqoop import --connect jdbc:mysql://hadoop102:3306/company \
--username root --password 000000 --table company --columns "id,name,sex" --column-family "info" --hbase-create-table --hbase-row-key "id" --hbase-table "hbase_company" --num-mappers 1 --split-by id
提示:sqoop1.4.6 只支持 HBase1.0.1 之前的版本的自动创建 HBase 表的功能
解决方案:手动创建 HBase 表
hbase> create ‘hbase_company,‘info‘
(5) 在 HBase 中 scan 这张表得到如下内容
hbase> scan ‘hbase_company’

2 导出数据

在 Sqoop 中,“导出”概念指:从大数据集群(HDFS,HIVE,HBASE)向非大数据集群(RDBMS)中传输数据,叫做:导出,即使用 export 关键字。
2.1 HIVE/HDFS 到 RDBMS
$ bin/sqoop export --connect jdbc:mysql://hadoop102:3306/company \
--username root --password 000000 --table staff --num-mappers 1 --export-dir /user/hive/warehouse/staff_hive --input-fields-terminated-by "\t"
提示:Mysql 中如果表不存在,不会自动创建

3 脚本打包

使用 opt 格式的文件打包 sqoop 命令,然后执行
1) 创建一个.opt 文件
$ mkdir opt
$ touch opt/job_HDFS2RDBMS.opt
2) 编写 sqoop 脚本
$ vi opt/job_HDFS2RDBMS.opt
export
--connect
jdbc:mysql://hadoop102:3306/company
--username
root
--password
000000
--table
staff
--num-mappers
1
--export-dir
/user/hive/warehouse/staff_hive
--input-fields-terminated-by
"\t"
3) 执行该脚本
$ bin/sqoop --options-file opt/job_HDFS2RDBMS.opt

 

Hbase基础(七):Sqoop 的简单使用案例

原文:https://www.cnblogs.com/qiu-hua/p/13401258.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!