导出NebulaGraph数据Graph

本文以一个示例说明如何使用Exchange将NebulaGraph中的数据导出到CSV文件中。

环境准备Graph

本示例在Linux系统的虚拟机环境下完成，导出数据前准备的软硬件信息如下。

硬件Graph

系统Graph

CentOS 7.9.2009

软件Graph

数据集Graph

在本示例中，作为数据源的NebulaGraph存储着Graph，其中的Schema要素如下表所示。

操作步骤Graph

1. 从Graph中获取企业版Exchange的JAR文件。

2. 修改配置文件。

   企业版Exchange提供了导出NebulaGraph数据专用的配置文件模板export_application.conf，其中各配置项的说明参见Graph。本示例使用的配置文件核心内容如下：

   ...
   
     # Processing tags
     # There are tag config examples for different dataSources.
     tags: [
       # export NebulaGraph tag data to csv, only support export to CSV for now.
       {
         name: player
         type: {
           source: Nebula
           sink: CSV
         }
         # the path to save the NebulaGrpah data, make sure the path doesn't exist.
         path:"hdfs://192.168.8.177:9000/vertex/player"
         # if no need to export any properties when export NebulaGraph tag data
         # if noField is configured true, just export vertexId
         noField:false
         # define properties to export from NebulaGraph tag data
         # if return.fields is configured as empty list, then export all properties
         return.fields:[]
         # nebula space partition number
         partition:10
       }
   
   ...
   
     ]
   
     # Processing edges
     # There are edge config examples for different dataSources.
     edges: [
       # export NebulaGraph tag data to csv, only support export to CSV for now.
       {
         name: follow
         type: {
           source: Nebula
           sink: CSV
         }
         # the path to save the NebulaGrpah data, make sure the path doesn't exist.
         path:"hdfs://192.168.8.177:9000/edge/follow"
         # if no need to export any properties when export NebulaGraph edge data
         # if noField is configured true, just export src,dst,rank
         noField:false
         # define properties to export from NebulaGraph edge data
         # if return.fields is configured as empty list, then export all properties
         return.fields:[]
         # nebula space partition number
         partition:10
       }
   
   ...
   
     ]
   }
   

3. 使用如下命令导出NebulaGraph中的数据。

   <spark_install_path>/bin/spark-submit --master "local" --class com.vesoft.nebula.exchange.Exchange nebula-exchange-x.y.z.jar_path> -c <export_application.conf_path>
   

   本示例使用的导出命令如下。

   $ ./spark-submit --master "local" --class com.vesoft.nebula.exchange.Exchange \
     ~/exchange-ent/nebula-exchange-ent-2.6.0.jar -c ~/exchange-ent/export_application.conf
   

4. 检查导出的数据。

   1. 查看目标路径下是否成功生成了CSV文件。

      $ hadoop fs -ls /vertex/player
      Found 11 items
      -rw-r--r--   3 nebula supergroup          0 2021-11-05 07:36 /vertex/player/_SUCCESS
      -rw-r--r--   3 nebula supergroup        160 2021-11-05 07:36 /vertex/player/    part-00000-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      -rw-r--r--   3 nebula supergroup        163 2021-11-05 07:36 /vertex/player/    part-00001-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      -rw-r--r--   3 nebula supergroup        172 2021-11-05 07:36 /vertex/player/    part-00002-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      -rw-r--r--   3 nebula supergroup        172 2021-11-05 07:36 /vertex/player/    part-00003-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      -rw-r--r--   3 nebula supergroup        144 2021-11-05 07:36 /vertex/player/    part-00004-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      -rw-r--r--   3 nebula supergroup        173 2021-11-05 07:36 /vertex/player/    part-00005-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      -rw-r--r--   3 nebula supergroup        160 2021-11-05 07:36 /vertex/player/    part-00006-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      -rw-r--r--   3 nebula supergroup        148 2021-11-05 07:36 /vertex/player/    part-00007-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      -rw-r--r--   3 nebula supergroup        125 2021-11-05 07:36 /vertex/player/    part-00008-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      -rw-r--r--   3 nebula supergroup        119 2021-11-05 07:36 /vertex/player/    part-00009-17293020-ba2e-4243-b834-34495c0536b3-c000.csv
      

   2. 检查CSV文件内容，确定数据导出成功。