Atlas Server 实体类型

背景

AtlasServer 实体类型是一种特殊的实体类型，体现在以下方面：

• 在导出或导入操作期间被创建。
• 它还具有特殊的属性页，用于显示导出和导入操作的详细审计信息。
• 实体通过实体属性中的新选项 SoftReference 与之关联。

该新类型可在 Basic（基本）和 Advanced（高级）搜索的 Search By Type（按类型搜索）下拉列表中找到。

创建

每当导出或导入操作成功完成时，都会创建该类型的实体。实体以当前集群的名称创建。

实体还会根据导出和导入请求中的 replicatedTo 和 replicatedFrom 参数创建。

属性页中的详细信息

AtlasServer 实体的属性页包含一个附加选项卡"Export/Import Audits"（导出/导入审计）。其中记录了在当前 Atlas 实例上执行的每次导出和/或导入操作的详细审计信息。

下面将详细介绍 additionalInfo 属性。

导出/导入审计

该表格包含以下列：

• Operation（操作）：EXPORT 或 IMPORT，表示在实例上执行的操作类型。
• Source Server（源服务器）：对于在本实例上执行的导出操作，此列的值始终为当前 Atlas 实例的集群名称。即 atlas-application.properties 文件中键 atlas.cluster.name 所指定的值。如果未指定，则使用 'default'。
• Target Server（目标服务器）：如果导出操作的请求中指定了 replicatedTo 属性，则该值显示在此处。
• Operation StartTime（操作开始时间）：操作开始的时间。
• Operation EndTime（操作结束时间）：操作完成的时间。
• Tools（工具）：弹出的属性页，其中包含操作的详细信息。

示例

以下导出请求将创建一个 AtlasServer 实体，其名称为 clMain。该操作的审计记录将显示在此实体的属性页中。

{
    "itemsToExport": [
        { "typeName": "hive_db", "uniqueAttributes": { "qualifiedName": "stocks@cl1" }}
    ],
    "options": {
        "replicatedTo": "clMain"
    }
}

支持集群全名

通常需要通过指定 Atlas 实例所在的位置或数据中心来消除集群名称的歧义。

集群名称可以通过用 '$' 分隔位置名称和集群名称来指定。例如，指定为 'SFO$cl1' 的集群名称，可以表示位于旧金山（SFO）数据中心、名称为 'cl1' 的集群。

AtlasServer 会处理这一点，并将其名称设置为 'cl1'，fullName 设置为 'SFO@cl1'。

附加信息

AtlasServer 中的该属性是一个键和值均为 String 的映射。它可以用来存储与该实例相关的任何信息。

有关如何使用该属性的示例，请参阅增量导出。

REST API

CURL

curl -X GET -u admin:admin -H "Content-Type: application/json" -H "Cache-Control:no-cache" http://localhost:21000/api/atlas/admin/server/cl2

Atlas Server

Atlas Server（Atlas 服务器）是 Apache Atlas 的核心进程，负责承载元数据的存储、检索、血缘分析以及各类系统服务接口。

概述

Atlas Server 同时扮演以下角色：

• 元数据存储：接收并持久化来自各类数据源的元数据。
• 类型系统管理：加载并维护类型定义（Type Definitions）。
• 搜索与发现：提供基于关键词、条件以及全文的元数据检索能力。
• 血缘分析：根据实体之间的关系计算并展示数据血缘。

架构

Atlas Server 内部主要包含以下模块：

启动服务

$ATLAS_HOME/bin/atlas_server.py start

停止服务：

$ATLAS_HOME/bin/atlas_server.py stop

配置

服务器的主要配置项位于 atlas.conf 目录下，常见配置包括：

• atlas.graph.storage.backend —— 图存储后端类型
• atlas.notification.embedded —— 是否使用内嵌 Kafka
• atlas.audit.hbase.ulog —— 是否启用 HBase 审计日志

::: tip 提示
修改配置后需要重启 Atlas Server 方可生效。
:::

健康检查

可通过以下接口确认服务状态：

GET /api/atlas/admin/status

返回结果中的 Status 字段为 STARTED 时表示服务运行正常。

相关链接

• REST API
• 类型系统
• 血缘信息

{
    "guid": "f87e4fd1-bfb5-482d-9ab1-e735621b7d16",
    "name": "cl2",
    "qualifiedName": "cl2",
    "additionalInfo": {
        "nextModifiedTimestamp": "1533037289383",
        "replicationOperation": "EXPORT",
        "topLevelEntity": "stocks@cl1"
    }
}