nebula-importer导入csv文件报错

nebula 版本:3.4.0
部署方式(分布式 / 单机 / Docker / DBaaS):单机
是否为线上版本:N
报错信息为:

./nebula-importer --config ./test_qwcs.yaml 
2023/03/28 17:32:37 --- START OF NEBULA IMPORTER ---
2023/03/28 17:32:37 [INFO] config.go:422: Failed data path: err/vertex_player.csv/vertex_player.csv
2023/03/28 17:32:37 [INFO] config.go:428: find file: /data/nebula/vertex_player.csv
2023/03/28 17:32:37 [INFO] config.go:422: Failed data path: err/edge_follow.csv/edge_follow.csv
2023/03/28 17:32:37 [INFO] config.go:428: find file: /data/nebula/edge_follow.csv
2023/03/28 17:32:37 [INFO] config.go:500: files[0].schema.vertex is nil
2023/03/28 17:32:52 [INFO] clientmgr.go:31: Create 10 Nebula Graph clients
2023/03/28 17:32:52 [INFO] runner.go:75: Start to read /data/nebula/vertex_player.csv
2023/03/28 17:32:52 [INFO] runner.go:75: Start to read /data/nebula/edge_follow.csv
2023/03/28 17:32:52 [INFO] runner.go:96: Waiting for stats manager done
2023/03/28 17:32:52 [INFO] reader.go:63: Start to read file(1): /data/nebula/edge_follow.csv, schema: < :SRC_VID(string)/follow.player100:string,:DST_VID(string)/follow.
player101:string,:RANK/follow.95:string >2023/03/28 17:32:52 [INFO] reader.go:49: The delimiter of /data/nebula/vertex_player.csv is U+002C ','
2023/03/28 17:32:52 [INFO] reader.go:63: Start to read file(0): /data/nebula/vertex_player.csv, schema: < :VID(string) >
2023/03/28 17:32:52 [INFO] reader.go:179: Total lines of file(/data/nebula/vertex_player.csv) is: 51, error lines: 0
2023/03/28 17:32:52 [INFO] runner.go:79: Finish to read /data/nebula/vertex_player.csv
2023/03/28 17:32:52 [INFO] reader.go:179: Total lines of file(/data/nebula/edge_follow.csv) is: 81, error lines: 0
2023/03/28 17:32:52 [INFO] runner.go:79: Finish to read /data/nebula/edge_follow.csv
2023/03/28 17:32:52 [ERROR] handler.go:63: Client 8 fail to execute: INSERT VERTEX  VALUES  "player103": (), "player139": (), "player112": (), "player117": (), "player14
1": (), "player147": (), "player148": ();, ErrMsg: SemanticError: Insert vertex is forbidden, please specify the tag, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 0 fail to execute: INSERT VERTEX  VALUES  "player118": (), "player144": (), "player114": ();, ErrMsg: SemanticError: In
sert vertex is forbidden, please specify the tag, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 5 fail to execute: INSERT VERTEX  VALUES  "player111": (), "player107": (), "player131": (), "player122": (), "player14
6": ();, ErrMsg: SemanticError: Insert vertex is forbidden, please specify the tag, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 3 fail to execute: INSERT VERTEX  VALUES  "player137": (), "player100": (), "player115": (), "player149": (), "player12
4": (), "player132": ();, ErrMsg: SemanticError: Insert vertex is forbidden, please specify the tag, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 7 fail to execute: INSERT VERTEX  VALUES  "player128": (), "player145": ();, ErrMsg: SemanticError: Insert vertex is fo
rbidden, please specify the tag, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 2 fail to execute: INSERT VERTEX  VALUES  "player116": (), "player113": (), "player130": (), "player101": (), "player14
2": (), "player119": (), "player127": ();, ErrMsg: SemanticError: Insert vertex is forbidden, please specify the tag, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 1 fail to execute: INSERT VERTEX  VALUES  "player109": (), "player125": (), "player121": (), "player136": (), "player11
0": (), "player126": (), "player133": (), "player140": (), "player102": (), "player138": (), "player134": (), "player150": (), "player135": ();, ErrMsg: SemanticError: Insert vertex is forbidden, please specify the tag, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 6 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player102"->"player100"@75:("player102",
"player100","75") , "player114"->"player140"@90:("player114","player140","90") , "player121"->"player129"@90:("player121","player129","90") , "player137"->"player136"@80:("player137","player136","80") , "player140"->"player114"@90:("player140","player114","90") , "player149"->"player130"@80:("player149","player130","80") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 9 fail to execute: INSERT VERTEX  VALUES  "player143": (), "player104": (), "player106": (), "player108": ();, ErrMsg: 
SemanticError: Insert vertex is forbidden, please specify the tag, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 4 fail to execute: INSERT VERTEX  VALUES  "player120": (), "player129": (), "player123": ();, ErrMsg: SemanticError: In
sert vertex is forbidden, please specify the tag, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 0 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player101"->"player100"@95:("player101",
"player100","95") , "player105"->"player100"@70:("player105","player100","70") , "player129"->"player128"@90:("player129","player128","90") , "player138"->"player139"@99:("player138","player139","99") , "player139"->"player138"@99:("player139","player138","99") , "player144"->"player100"@80:("player144","player100","80") , "player150"->"player143"@90:("player150","player143","90") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 8 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player105"->"player116"@80:("player105",
"player116","80") , "player121"->"player116"@90:("player121","player116","90") , "player127"->"player114"@90:("player127","player114","90") , "player135"->"player102"@80:("player135","player102","80") , "player137"->"player148"@80:("player137","player148","80") , "player143"->"player150"@90:("player143","player150","90") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 1 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player101"->"player102"@90:("player101",
"player102","90") , "player103"->"player102"@70:("player103","player102","70") , "player113"->"player100"@99:("player113","player100","99") , "player113"->"player105"@99:("player113","player105","99") , "player113"->"player120"@99:("player113","player120","99") , "player113"->"player121"@99:("player113","player121","99") , "player113"->"player125"@99:("player113","player125","99") , "player120"->"player118"@80:("player120","player118","80") , "player127"->"player148"@70:("player127","player148","70") , "player128"->"player116"@90:("player128","player116","90") , "player131"->"player118"@95:("player131","player118","95") , "player133"->"player144"@90:("player133","player144","90") , "player148"->"player127"@80:("player148","player127","80") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [INFO] statsmgr.go:91: Done(/data/nebula/vertex_player.csv): Time(15.06s), Finished(69), Failed(69), Read Failed(0), Latency AVG(0us), Batches Req AV
G(0us), Rows AVG(4.58/s)2023/03/28 17:32:52 [INFO] statsmgr.go:134: Remaining read files 1
2023/03/28 17:32:52 [ERROR] handler.go:63: Client 5 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player100"->"player125"@95:("player100",
"player125","95") , "player118"->"player131"@90:("player118","player131","90") , "player136"->"player117"@90:("player136","player117","90") , "player136"->"player147"@90:("player136","player147","90") , "player138"->"player115"@90:("player138","player115","90") , "player150"->"player120"@80:("player150","player120","80") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 2 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player118"->"player120"@90:("player118",
"player120","90") , "player124"->"player141"@-1:("player124","player141","-1") , "player134"->"player121"@-1:("player134","player121","-1") , "player137"->"player129"@10:("player137","player129","10") , "player144"->"player145"@100:("player144","player145","100") , "player150"->"player137"@90:("player150","player137","90") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 3 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player104"->"player100"@55:("player104",
"player100","55") , "player104"->"player101"@50:("player104","player101","50") , "player105"->"player104"@83:("player105","player104","83") , "player113"->"player101"@99:("player113","player101","99") , "player113"->"player116"@99:("player113","player116","99") , "player116"->"player141"@10:("player116","player141","10") , "player128"->"player121"@90:("player128","player121","90") , "player129"->"player121"@90:("player129","player121","90") , "player142"->"player117"@90:("player142","player117","90") , "player148"->"player136"@90:("player148","player136","90") , "player148"->"player137"@85:("player148","player137","85") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 9 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player108"->"player101"@80:("player108",
"player101","80") , "player113"->"player118"@99:("player113","player118","99") , "player130"->"player149"@80:("player130","player149","80") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 4 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player101"->"player125"@95:("player101",
"player125","95") , "player102"->"player101"@75:("player102","player101","75") , "player109"->"player100"@80:("player109","player100","80") , "player114"->"player103"@90:("player114","player103","90") , "player129"->"player116"@90:("player129","player116","90") , "player136"->"player137"@88:("player136","player137","88") , "player136"->"player148"@85:("player136","player148","85") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [ERROR] handler.go:63: Client 7 fail to execute: INSERT EDGE `follow`(`player100`,`player101`,`95`) VALUES  "player104"->"player105"@60:("player104",
"player105","60") , "player107"->"player100"@80:("player107","player100","80") , "player108"->"player100"@80:("player108","player100","80") , "player109"->"player125"@90:("player109","player125","90") , "player113"->"player104"@99:("player113","player104","99") , "player113"->"player106"@99:("player113","player106","99") , "player113"->"player119"@99:("player113","player119","99") , "player114"->"player115"@90:("player114","player115","90") , "player121"->"player128"@90:("player121","player128","90") , "player125"->"player100"@90:("player125","player100","90") , "player126"->"player116"@13:("player126","player116","13") , "player128"->"player129"@90:("player128","player129","90") , "player133"->"player114"@90:("player133","player114","90") , "player141"->"player124"@9:("player141","player124","9") , "player147"->"player136"@90:("player147","player136","90") ;, ErrMsg: SemanticError: Unknown column `player100' in schema, ErrCode: -10092023/03/28 17:32:52 [INFO] statsmgr.go:91: Done(/data/nebula/edge_follow.csv): Time(15.06s), Finished(130), Failed(130), Read Failed(0), Latency AVG(0us), Batches Req AV
G(0us), Rows AVG(8.63/s)2023/03/28 17:32:52 [INFO] statsmgr.go:134: Remaining read files 0
2023/03/28 17:32:52 [INFO] runner.go:98: Waiting for all readers exit
2023/03/28 17:32:52 [INFO] runner.go:109: All readers exited
2023/03/28 17:32:52 [INFO] clientmgr.go:37: Client manager closing
2023/03/28 17:32:52 [INFO] clientmgr.go:39: Client manager closed
2023/03/28 17:32:52 [INFO] statsmgr.go:56: Stats manager closing
2023/03/28 17:32:52 [INFO] statsmgr.go:61: Stats manager closed
2023/03/28 17:32:53 Total 130 lines fail to insert into nebula graph database
2023/03/28 17:32:54 --- END OF NEBULA IMPORTER ---
````预先格式化的文本`
yaml配置为:
# 连接的 Nebula Graph 版本,连接 3.x 时设置为 v3。
version: v2

description: example

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

clientSettings:

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

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

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

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

  # 连接信息。
  connection:
    user: root
    password: 123456
    address: 192.168.91.133:9669

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


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

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

# 错误等日志信息输出的文件路径。    
logPath: ./err/test.log

# CSV 文件相关设置。
files:

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

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

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

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

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

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

      # 是否有 LABEL。
      withLabel: false

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

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

    # 本示例第二个数据文件为边的数据。
  - path: ./edge_follow.csv
    failDataPath: ./err/edge_follow.csv
    batchSize: 100
    inOrder: true
    type: csv
    csv:
      withHeader: true
      withLabel: false
    schema:
      # Schema 的类型为 edge。
      type: edge
      edge:
        # Edge type 名称。
        name: follow

        # 是否包含 rank。
        withRanking: true


csv数据格式为:
player100,player101,95
player100,player125,95
player101,player100,95
player101,player102,90
player101,player125,95
player102,player100,75
player102,player101,75
1 个赞

你之前的问题没有解决也没有回复啊,不需要开新的帖子的,会增加回复资源分散的,你可以去更新下原帖,这个帖子先行关闭了,回复以之前帖子为准。要更新信息的话,只要重新回复下就好了。