跳转至

有表头配置说明

对于有表头(header)的 CSV 文件,需要在配置文件里设置withHeadertrue,表示 CSV 文件中第一行为表头,表头内容具有特殊含义。

Caution

如果 CSV 文件中含有 header,Importer 就会按照 header 来解析每行数据的 Schema,并忽略 yaml 文件中的点或边设置。

示例文件

有表头的 CSV 文件示例如下:

  • 点示例

    student_with_header.csv的示例数据:

    csv :VID(string),student.name:string,student.age:int,student.gender:string student100,Monica,16,female student101,Mike,18,male student102,Jane,17,female

    第一列为点 ID,后面三列为属性nameagegender

  • 边示例

    follow_with_header.csv的示例数据:

    csv :SRC_VID(string),:DST_VID(string),:RANK,follow.degree:double student100,student101,0,92.5 student101,student100,1,85.6 student101,student102,2,93.2 student100,student102,1,96.2

    前两列的数据分别为起始点 ID 和目的点 ID,第三列为 rank,第四列为属性degree

表头格式说明

表头通过一些关键词定义起始点、目的点、rank 以及一些特殊功能,说明如下:

  • :VID(必填):点 ID。需要用:VID(type)形式设置数据类型,例如:VID(string):VID(int)
  • :SRC_VID(必填):边的起始点 ID。需要用:SRC_VID(type)形式设置数据类型。
  • :DST_VID(必填):边的目的点 ID。需要用:DST_VID(type)形式设置数据类型。
  • :RANK(可选):边的 rank 值。
  • :IGNORE(可选):插入数据时忽略这一列。
  • :LABEL(可选):表示对该行进行插入(+)或删除(-)操作。必须为第一列。例如:

    csv :LABEL, +, -,

Note

除了:LABEL列之外的所有列都可以按任何顺序排序,因此针对较大的 CSV 文件,用户可以灵活地设置 header 来选择需要的列。

对于 Tag 或 Edge type 的属性,格式为<tag_name/edge_name>.<prop_name>:<prop_type>,说明如下:

  • <tag_name/edge_name>:Tag 或者 Edge type 的名称。
  • <prop_name>:属性名称。
  • <prop_type>:属性类型。支持boolintfloatdoubletimestampstring,默认为string

例如student.name:stringfollow.degree:double

配置示例

```yaml

连接的 Nebula Graph 版本,连接 3.x 时设置为 v3。

version: v3

description: example

是否删除临时生成的日志和错误数据文件。

removeTempFiles: false

clientSettings:

# nGQL 语句执行失败的重试次数。 retry: 3

# Nebula Graph 客户端并发数。 concurrency: 10

# 每个 Nebula Graph 客户端的缓存队列大小。 channelBufferSize: 128

# 指定数据要导入的 Nebula Graph 图空间。 space: student

# 连接信息。 connection: user: root password: nebula address: 192.168.11.13:9669

postStart: # 配置连接 Nebula Graph 服务器之后,在插入数据之前执行的一些操作。 commands: | DROP SPACE IF EXISTS student; CREATE SPACE IF NOT EXISTS student(partition_num=5, replica_factor=1, vid_type=FIXED_STRING(20)); USE student; CREATE TAG student(name string, age int,gender string); CREATE EDGE follow(degree int);

# 执行上述命令后到执行插入数据命令之间的间隔。
afterPeriod: 15s

preStop: # 配置断开 Nebula Graph 服务器连接之前执行的一些操作。 commands: |

错误等日志信息输出的文件路径。

logPath: ./err/test.log

CSV 文件相关设置。

files:

# 数据文件的存放路径,如果使用相对路径,则会将路径和当前配置文件的目录拼接。本示例第一个数据文件为点的数据。

- path: ./student_with_header.csv

# 插入失败的数据文件存放路径,以便后面补写数据。
failDataPath: ./err/studenterr.csv

# 单批次插入数据的语句数量。
batchSize: 10

# 读取数据的行数限制。
limit: 10

# 是否按顺序在文件中插入数据行。如果为 false,可以避免数据倾斜导致的导入速率降低。
inOrder: true

# 文件类型,当前仅支持 csv。
type: csv

csv:
  # 是否有表头。
  withHeader: true

  # 是否有 LABEL。
  withLabel: false

  # 指定 csv 文件的分隔符。只支持一个字符的字符串分隔符。
  delimiter: ","

schema:
  # Schema 的类型,可选值为 vertex 和 edge。
  type: vertex

# 本示例第二个数据文件为边的数据。

- path: ./follow_with_header.csv failDataPath: ./err/followerr.csv batchSize: 10 limit: 10 inOrder: true type: csv csv: withHeader: true withLabel: false schema: # Schema 的类型为 edge。 type: edge edge: # Edge type 名称。 name: follow

    # 是否包含 rank。
    withRanking: true

```

Note

点 ID 的数据类型需要和clientSettings.postStart.commands中的创建图空间语句的数据类型一致。


最后更新: 2026年8月17日