189 8069 5689

Sqoop1如何导入导出

这篇文章主要介绍Sqoop1如何导入导出,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!

让客户满意是我们工作的目标,不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户,将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴,公司提供的服务项目有:域名与空间、虚拟空间、营销软件、网站建设、新市网站维护、网站推广。

 》Sqoop1 和 Sqoop2 的区别 

Sqoop1 由 Client 端直接接入 Hadoop,任务通过解析生成对应的 MR 执行

Sqoop1 仅有一个客户端,架构简单明了,部署即用,使用门槛比较低,但是耦合性强,用户密码暴露不安全

Sqoop2 服务端部署,运行,提供 Cli、rest api、webui 等入口,Connector 集中管理,RDBMS控制账户更安全,但是 Sqoop2 仅负责数据的读写操作,架构相对复杂

 》Sqoop1导入(MySQL 导入到 HDFS)

注意:首先要启动MySQL、ZK、Hadoop

# demo1:table

# sqoop1 导入命令 mysql=>hdfs
bin/sqoop import 
# mysql驱动类
--driver com.mysql.cj.jdbc.Driver
# 连接字符串 
--connect jdbc:mysql://192.168.56.1/dbName?serverTimezone=GMT%2B8
# 从哪张表导数据
--table tbName
# mysql账号 
--username root
# mysql 密码 
--password 123456 
--verbose 
# 目标目录(HDFS)
--target-dir=/sqoop/a_users

# demo2:query

# 导入数据
# --query和--table是互斥的;
bin/sqoop import 
--connect jdbc:mysql://192.168.56.1/dbName?serverTimezone=GMT%2B8
--username root 
--password 123456 
--verbose 
# 获取记录条数
--fetch-size 30 
# SQL 语句
# $CONDITIONS sql语句执行的条件,这个条件由sqoop自己控制
--query 'select * from a_users where $CONDITIONS' 
# 按照 id 切分
#--split-by;拆分的这一列不能重复,一般是主键
--split-by id  
# 目标目录(HDFS)
--target-dir=/sqoop/a_users

# demo3:将sqoop脚本封装在文件中

# 新建一个文件;(一行一个,使用#注释);文件名随便写
import
--connect jdbc:mysql://192.168.56.1/dbName?serverTimezone=GMT%2B8
--username root
--password 123456
--verbose
--fetch-size 30
--query 'select * from a_users where $CONDITIONS'
--split-by id
--target-dir=/sqoop/a_users

执行Sqoop脚本文件的命令

bin/sqoop --options-file /root/fileName.txt

以上是“Sqoop1如何导入导出”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注创新互联行业资讯频道!


文章名称:Sqoop1如何导入导出
当前地址:http://jkwzsj.com/article/ipgges.html

其他资讯