首页 > 代码库 > Sqoop

Sqoop

Sqoop是什么

Sqoop 是连接传统关系型数据库和Hadoop 的桥梁,主要功能是,

  把关系型数据库的数据导入到Hadoop 系统( 如HDFS、HBase 和Hive) 中

  把数据从Hadoop 系统里抽取并导出到关系型数据库里

可以利用MapReduce 加快数据传输速度,使用批处理的方式进行数据传输

关系数据库与Hadoop之间传递数据

全量导入:

sqoop

增量导入:

Canal(https://github.com/alibaba/canal)

DataBus(https://github.com/linkedin/databus )

Sqoop import

将数据从关系型数据库导入Hadoop中

  1、Sqoop与数据库Server 通信,获取数据库表的元数据信息

  2、Sqoop启动一个Map-Only的MR作业,利用元数据信息并行将数据写入Hadoop

Sqoop import使用方法

sqoop import --connect jdbc:mysql://mysql.example.com/sqoop \
--username sqoop --password sqoop --table cities
注:
--connnect: 指定JDBC URL
--username/password:mysql数据库的用户名
--table:要读取的数据库表

Sqoop export

将数据从Hadoop导入关系型数据库导中

  1、Sqoop与数据库Server 通信,获取数据库表的元数据信息

  2、并行导入数据,将Hadoop上文件划分成若干个split,每个split由一个Map Task进行数据导入

Sqoop export使用方法

sqoop export --connect jdbc:mysql://mysql.example.com/sqoop \
--username sqoop --password sqoop --table cities --export-dir cities
注:
--connnect: 指定JDBC URL
--username/password:mysql数据库的用户名
--table:要导入的数据库表
export-dir:数据在HDFS上存放目录

Sqoop 与其他系统结合

sqoop import --connect jdbc:mysql://mysql.example.com/sqoop \
--username sqoop --password sqoop --table cities --hive-import

sqoop import --connect jdbc:mysql://mysql.example.com/sqoop \
--username sqoop --password sqoop --table cities --hbase-table cities --column-family world

 

Sqoop