Atlas集成Sqoop

发布时间 2024-01-08 13:36:08作者: 粒子先生

注册hook

编辑sqoop‐site.xml,添加如下配置

<property>
<name>sqoop.job.data.publish.class</name>
<value>org.apache.atlas.sqoop.hook.SqoopHook</value>
</property>

引入依赖

ln /opt/apps/apache‐atlas‐2.1.0/hook/sqoop/* /opt/apps/sqoop‐1.4.7/lib/
 

引入配置

# 拷贝一个atlas‐application.properties文件到sqoop的conf目录中,并添加如下配置

atlas.hook.sqoop.synchronous=false
atlas.hook.sqoop.numRetries=3
atlas.hook.sqoop.queueSize=10000
 

验证

创建表
sqoop create-hive-table --hive-table data_model --connect jdbc:mysql://172.31.6.92:30278/metadata --table data_model --username root --password Jcinfo@1995
导入表
sqoop import -hive-import --connect jdbc:mysql://172.31.6.92:30278/metadata  --username root --password Jcinfo@1995 --table data_source --hive-overwrite -m 1