04-用户画像+sqoop使用
优点
sqoop的作用是实现数据的导入和导出,主要是对数据库和数据仓库之间的操作
只要是支持jdbc连接的数据库都可以使用sqoop操作
添加Sqoop到环境变量中
export SQOOP_HOME=/export/server/sqoop
export PATH=$PATH:$SQOOP_HOME/bin:$SQOOP_HOME/sbin
source /etc/profile
启动数仓服务
./up01.sh start
sqoop建表语句
create database itcast charset=utf8;
create table itcast.tb_user(
id int,
name varchar(20),
age int,
gender varchar(20)
);
insert into itcast.tb_user value(1,'张三',20,'男');
hive数仓中的准备
create database itcast;
hive表指令
- create-hive-table 根据mysql表创建hive表
- –connect mysql连接信息 jdbc连接
- –username mysql用户名
- –password mysql密码
- –table mysql表名
- –hive-table hive表名 需要指定库
- –fields-terminated-by 字段分割符
/export/server/sqoop/bin/sqoop create-hive-table --connect jdbc:mysql://192.168.88.166:3306/users --username root --password 123456 --table tbl_users --hive-table users.tbl_users --fields-terminated-by '\t'
sqoop导入数据指令
- mysql数据导入数仓
- import 根据mysql表创建
- –connect mysql连接信息
- –username 用户名
- –password 密码
- –table mysql表名
- –hive-import 导入hive表
- –hive-overwrite 覆盖导入
- –hive-table hive表名
- –fields-terminated-by 字段分割符
- –delete-target-dir 如果存在表目录则删除后在再重新创建
- –direct 直接导入模式 提升导入速度
- –m 指定Maptask数量并行导入数据
/export/server/sqoop/bin/sqoop import --connect jdbc:mysql://192.168.88.166:3306/users --username root --password 123456 --table tbl_users --hive-import --hive-overwrite --hive-table users.tbl_users --fields-terminated-by '\t' --delete-target-dir --direct --m 1
编写sqoop脚本
qoop脚本就是将sqoop指令写入shell文件 后缀是 .sh
建表脚本
/export/server/sqoop/bin/sqoop \
create-hive-table \
--connect jdbc:mysql://192.168.88.166:3306/users \
--username root \
--password 123456 \
--table tbl_users \
--hive-table users.tbl_users \
--fields-terminated-by '\t'
导入脚本
/export/server/sqoop/bin/sqoop \
import \
--connect jdbc:mysql://192.168.88.166:3306/users \
--username root \
--password 123456 \
--table tbl_users \
--hive-import \
--hive-overwrite \
--hive-table users.tbl_users \
--fields-terminated-by '\t' \
--delete-target-dir \
--direct \
--m 1
原文地址:https://blog.csdn.net/weixin_46567476/article/details/140588874
免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!