导入ClickHouse数据

本文以basketballplayer数据集为例。

本文示例在MacOS下完成，以下是相关的环境配置信息：

• 硬件规格：

  • CPU：1.7 GHz Quad-Core Intel Core i7
  • 内存：16 GB

• Spark：2.4.7，单机版

• Hadoop：2.9.2，伪分布式部署

• ClickHouse：docker部署yandex/clickhouse-server tag: latest(2021.07.01)

开始导入数据之前，用户需要确认以下信息：

• • Graph服务和Meta服务的的IP地址和端口。

  • 拥有Nebula Graph写权限的用户名和密码。

• 已经编译Exchange。详情请参见。本示例中使用Exchange 2.1.0。

• 已经安装Spark。

• 了解Nebula Graph中创建Schema的信息，包括Tag和Edge type的名称、属性等。

• 已经安装并开启Hadoop服务。

分析数据，按以下步骤在Nebula Graph中创建Schema：

更多信息，请参见快速开始。

编译Exchange后，复制文件设置ClickHouse数据源相关的配置。在本示例中，复制的文件名为clickhouse_application.conf。各个配置项的详细说明请参见。

运行如下命令将ClickHouse数据导入到Nebula Graph中。关于参数的说明，请参见导入命令参数。

示例：

用户可以在返回信息中搜索batchSuccess.<tag_name/edge_name>，确认成功的数量。例如batchSuccess.follow: 300。

用户可以在Nebula Graph客户端（例如Nebula Graph Studio）中执行查询语句，确认数据是否已导入。例如：

用户也可以使用命令查看统计数据。

导入数据后，用户可以在Nebula Graph中重新创建并重建索引。详情请参见索引介绍。