Nebula Importer¶

Nebula Importer (Importer) is a standalone import tool for CSV files with Nebula Graph. Importer can read the local CSV file and then import the data into the Nebula Graph database.

Scenario¶

Importer is used to import the contents of a local CSV file into the Nebula Graph.

Advantage¶

• Lightweight and fast: no complex environment can be used, fast data import.

• Flexible filtering: You can flexibly filter CSV data through configuration files.

Prerequisites¶

Before using Nebula Importer, make sure:

• Nebula Graph service has been deployed. There are currently three deployment modes:

  • Deploy Nebula Graph with Docker Compose
  • Install Nebula Graph with RPM or DEB package
  • Install Nebula Graph by compiling the source code

• Schema is created in Nebula Graph, including space, Tag and Edge type, or set by parameter clientSettings.postStart.commands.

• Golang environment has been deployed on the machine running the Importer. For details, see Build Go environment.

Steps¶

Configure the YAML file and prepare the CSV file to be imported to use the tool to batch write data to Nebula Graph.

Source code compile and run¶

1. Clone repository.

   $ git clone -b 2.5.0 https://github.com/vesoft-inc/nebula-importer.git
   

   Note

   Use the correct branch. Nebula Graph 1.x and 2.x have different RPC protocols, so:

   • The Nebula Importer V1 branch can only connect to Nebula Graph 1.x.
   • The Nebula Importer Master branch and v2 branch can connect to Nebula Graph 2.x.

2. Access the directory nebula-importer.

   $ cd nebula-importer
   

3. Compile the source code.

   $ make build
   

4. Start the service.

   $ ./nebula-importer --config <yaml_config_file_path>
   

   Note

   For details about the YAML configuration file, see configuration file description at the end of topic.

No network compilation mode¶

If the server cannot be connected to the Internet, it is recommended to upload the source code and various dependency packages to the corresponding server for compilation on the machine that can be connected to the Internet. The operation steps are as follows:

1. Clone repository.

   $ git clone -b 2.5.0 https://github.com/vesoft-inc/nebula-importer.git
   

2. Use the following command to download and package the dependent source code.

   $ cd nebula-importer
   $ go mod vendor
   $ cd .. && tar -zcvf nebula-importer.tar.gz nebula-importer
   

3. Upload the compressed package to a server that cannot be connected to the Internet.

4. Unzip and compile.

   $ tar -zxvf nebula-importer.tar.gz 
   $ cd nebula-importer
   $ go build -mod vendor cmd/importer.go
   

Run in Docker mode¶

Instead of installing the Go locale locally, you can use Docker to pull the image of the Nebula Importer and mount the local configuration file and CSV data file into the container. The command is as follows:

$ docker run --rm -ti \
    --network=host \
    -v <config_file>:<config_file> \
    -v <csv_data_dir>:<csv_data_dir> \
    vesoft/nebula-importer:<version>
    --config <config_file>

• <config_file>: The absolute path to the local YAML configuration file.
• <csv_data_dir>: The absolute path to the local CSV data file.
• <version>: Nebula Graph 2.x Please fill in 'v2'.

Configuration File Description¶

Nebula Importer uses configuration(nebula-importer/examples/v2/example.yaml) files to describe information about the files to be imported, the Nebula Graph server, and more. You can refer to the example configuration file: Configuration without Header/Configuration with Header. This section describes the fields in the configuration file by category.

Basic configuration¶

The example configuration is as follows:

version: v2
description: example
removeTempFiles: false

Client configuration¶

The client configuration stores the configurations associated with Nebula Graph.

The example configuration is as follows:

clientSettings:
  retry: 3
  concurrency: 10
  channelBufferSize: 128
  space: test
  connection:
    user: user
    password: password
    address: 192.168.*.13:9669,192.168.*.14:9669
  postStart:
    commands: |
      UPDATE CONFIGS storage:wal_ttl=3600;
      UPDATE CONFIGS storage:rocksdb_column_family_options = { disable_auto_compactions = true };
    afterPeriod: 8s
  preStop:
    commands: |
      UPDATE CONFIGS storage:wal_ttl=86400;
      UPDATE CONFIGS storage:rocksdb_column_family_options = { disable_auto_compactions = false };

File configuration¶

File configuration Stores the configuration of data files and logs, and details about the Schema.

File and log configuration¶

The example configuration is as follows:

logPath: ./err/test.log
files:
  - path: ./student_without_header.csv
    failDataPath: ./err/studenterr.csv
    batchSize: 128
    limit: 10
    inOrder: false
    type: csv
    csv:
      withHeader: false
      withLabel: false
      delimiter: ","

Schema configuration¶

Schema configuration describes the Meta information of the current data file. Schema types are vertex and edge. Multiple vertexes or edges can be configured at the same time.

• vertex configuration

The example configuration is as follows:

schema:
  type: vertex
  vertex:
    vid:
      type: string
      index: 0
    tags:
      - name: student
        props:
          - name: name
            type: string
            index: 1
          - name: age
            type: int
            index: 2
          - name: gender
            type: string
            index: 3

• edge configuration

The example configuration is as follows:

schema:
  type: edge
  edge:
    name: follow
    withRanking: true
    srcVID:
      type: string
      index: 0
    dstVID:
      type: string
      index: 1
    rank:
      index: 2
    props:
      - name: degree
        type: double
        index: 3

About the CSV file header¶

According to whether the CSV file has a header or not, the Importer needs to make different Settings on the configuration file. For relevant examples and explanations, please refer to:

• Configuration without Header

• Configuration with Header