Atlas2.2.0编译、安装及使用(集成ElasticSearch，导入Hive数据)

  • Z时代
  • 2024-01-10
  • 分类：综合

database

在数仓项目中，我们常常会选择Apache Atlas进行数据的治理。本文结合笔者在生产环境中遇到的常见问题及解决方法，整合出完整的Atlas编译、部署及使用过程。

1、编译阶段

组件信息：

组件名称

版本

Atals

2.2.0

HBase

2.2.6

Hive

3.1.2

Hadoop

3.1.1

Kafka

2.11_2.4.1

Zookeeper

3.6.2

ElasticSearch

7.12.1

 

架构: x86 (已知arm编译时会报node-sass缺少的问题，git上没有对应arm架构的包)

操作系统：CentOS 7.6

说明：

1、编译不包括其内嵌的HBase和Solr，只编译Atlas本身

2、下面的步骤中有些并非编译过程报错，而是具体使用中或导入hive元数据时报的错，提前修改

步骤：

step1：官网下载Atlas-2.2.0源码,解压

 

step2：配个国内源。可以在maven的conf目录下settings.xml里配置，也可以在项目的pom.xml里配置，这里贴阿里源做参考

 

step3：提前从Here下一个nodejs的包放到maven仓库下，目录参考

$MAVEN_REPOSITORY/com/github/eirslett/node/12.16.0/node-12.16.0-linux-x64.tar.gz

注意下下来的包名字叫node-v12.16.0-linux-x64.tar.gz，放在maven仓库里的时候要把里面的v去掉。如果不提前下，编译时候自己下载的速度很慢

step4：主pom.xml里添加下面两个依赖

                        <dependency>
                <groupId>org.restlet.jee</groupId>
                <artifactId>org.restlet</artifactId>
                <version>2.4.0</version>
            </dependency>
            
            <dependency>
                <groupId>org.restlet.jee</groupId>
                <artifactId>org.restlet.ext.servlet</artifactId>
                <version>2.4.0</version>
            </dependency>

 

step5：修改./intg/src/main/java/org/apache/atlas/ApplicationProperties.java

注释掉line 365 LOG.info("Setting " + SOLR_WAIT_SEARCHER_CONF + " = " + getBoolean(SOLR_WAIT_SEARCHER_CONF));

这步是因为我们采用es作为查询引擎，solr的相关配置都会注释掉，而这行调用会在导入hive元数据的时候报错

 

step6：把项目里的jsr311-api改成javax.ws.rs-api  (6处，可以直接在项目目录下grep -rn搜)， 并修改主pom.xml中jsr.version为2.0.1

这步主要影响六个支持的组件的数据导入及后续，包括hbase、hive、sqoop、impala、falcon、storm

主要原因：jsr311-api包中javax.ws.rs.core包中没有Link类，而Atlas以HBase作为元数据存储，HBase本身使用的为javax.ws.rs-api包中的core包，其中有Link类，所以调用脚本导入数据时会报以下错误

step7：执行编译命令mvn clean package -DskipTests -Drat.skip=true -Pdist

编译后的包在./distro/target目下,server包即为Atlas部署包，bin包为集成了常用hook(如hbase-hook)的部署包

 

2、部署阶段

前置条件：

集群内有正常运行且可用的hadoop、hive、hbase、kafka、zk、es，且atlas所在节点必须有hbase及hive的配置文件目录

步骤：

step1:解压atlas-bin包(这里以/data/apps为例，顺便改个名

tar -zxvf apache-atlas-2.2.0-bin.tar.gz -C /data/apps
mv apache-atlas-2.2.0 atlas-2.2.0

 

step2:解压hook包(这里以hive-hook为例)，并拷贝内容到atlas安装目录下

tar -zxvf apache-atlas-2.2.0-hive-hook.tar.gz -C /data/apps/
/usr/bin/cp /data/apps/apache-atlas-hive-hook-2.2.0/* /data/apps/atlas-2.2.0/

 

step3:修改atlas配置文件(有的配置是已有的，修改即可；有的配置没有，需要加)

atlas-application.properties:

     #atlas server config
             atlas.rest.address=http://atlas-ip:21000
        atlas.server.run.setup.on.start=false
     #hbase config
        atlas.audit.hbase.tablename=apache_atlas_entiry_audit
        atuls.audit.zookeeper.session.timeout.ms=1000
        atlas.audit.hbase.zookeeper.quorum=zk地址
             atlas.graph.storage.hostname=zk地址
     #solr config
      #注释掉所有和solr相关的配置项
     #es config
              atlas.graph.index.search.backend=elasticsearch
        atlas.graph.index.search.hostname=es-ip:9200
        atlas.graph.index.search.elasticsearch.client-only=true
        atlas.graph.index.search.elasticsearch.http.auth.type=basic
        atlas.graph.index.search.elasticsearch.http.auth.basic.username=elastic
        atlas.graph.index.search.elasticsearch.http.auth.basic.password=Cestc!666
    #kafka config
             atlas.nofification.embedded=false
        atlas.kafka.data=/data/log/kafka
        atlas.kafka.zookeeper.connect=zk地址/kafkaCluster
        atlas.kafka.bootstrap.servers=kafka地址
    #hive config
             atlas.hook.hive.numRetries=3
        atlas.hook.hive.queueSize=10000
        atlas.cluster.name=primary

atlas-env.sh:

        export HBASE_CONF_DIR=/data/apps/hbase-2.2.6/conf

atlas-log4j.xml:

        #去掉org.apache.log4j.DailyRollingFileAppender一块的注释来暴露性能指标

 

step4:将atlas-application.properties分发到所有hive所在节点的hive/conf目录下

 

step5:分发hive-hook目录到hive节点下,并修改hive配置文件

ssh hive-node "mkdir -p /data/apps/atlas-2.2.0/hook"
scp -r /data/apps/atlas-2.2.0/hook/hive hive-node:$PWD

hive-site.xml

           <property>
            <name>hive.exec.post.hooks</name>
            <value>org.apache.atlas.hive.hook.HiveHook</value>
        </property>

hive-env.sh

       export HIVE_AUX_JARS_PATH=/data/apps/atlas-2.2.0/hook/hive

 

step6:重启Hive

 

step7:调用atlas启动脚本启动服务

$ATLAS_HONE/bin/atlas_start.py

启动过程如下图所示

该过程会耗时较久，包含index创建、数据的初始化等操作

此时可以跟一下atlas的启动日志，直到日志不再刷新，再lsof或netstat查一下21000是否已经监听了，如已存在，则打开浏览器输入ip:21000登录atlas页面

千万不要相信他提示的Apache Atlas Server started!!!和jps显示的Atlas进程，因为启动脚本超过一定时间后一定会报成功，但此时21000端口还未被监听，服务是不可用的，真正可用还是以21000被成功监听，可以进到Atlas登录页面为准


 

3、使用阶段

说明：

此处我们以Hive的元数据导入及使用为例，其它数据源使用类似

 

步骤：

step1:进入atlas安装目录下，执行hook-bin中的import-hive.sh脚本

$ATLAS_HOME/hook-bin/import-hive.sh

执行后如下图

过程中会提示输入atlas用户名和密码，都输入admin即可

成功后会提示

该过程时间视hive现有数据量大小而定

 

step2:登录Atlas Web页面

打开浏览器输入ip:21000登录atlas页面


 

登录后如下图

此时可以点击右上角小图标

查看总体数据情况


 

查看所有hive表


 

随便点击一个表查看详情

可以清楚地看到这个表的各项信息、字段及血缘图等

 

我们也可以通过左侧搜索栏检索过滤想要查找的项


 

以上就是我在生产环境中部署Atlas-2.2.0并集成es、hive的过程，使用时可以点击页面操作，也可通过调用Rest API集成到自己系统里用

本文首发于云海天，作者榆天紫夏，希望对大家有所帮助。原文地址https://www.cnblogs.com/yutianzixia/p/16257916.html。如有遗漏或问题欢迎补充指正

本文来自云海天，作者：榆天紫夏，转载请注明原文链接：https://www.cnblogs.com/yutianzixia/p/16257916.html

以上是 Atlas2.2.0编译、安装及使用(集成ElasticSearch，导入Hive数据) 的全部内容， 来源链接： utcz.com/z/536508.html

回到顶部