Exchange 报错

为了更快地定位、解决问题,麻烦参考下面模版提问 ^ ^

提问参考模版:

  • nebula 版本:1.1.0
  • 部署方式(分布式 / 单机 / Docker / DBaaS):虚拟机
  • 硬件信息
    • 磁盘( 必须为 SSD ,不支持 HDD)
    • CPU、内存信息:
  • 出问题的 Space 的创建方式:执行 describe space xxx;
{
  # Spark 相关配置
  spark: {
    app: {
      name: Spark Writer
    }

    driver: {
      cores: 1
      maxResultSize: 1G
    }

    cores {
      max: 16
    }
  }

  # Nebula Graph 相关配置
  nebula: {
    address:{
      # 以下为 Nebula Graph 的 Graph 服务和 Meta 服务所在机器的 IP 地址及端口。
      # 如果有多个地址,格式为 "ip1:port","ip2:port","ip3:port"。
      # 不同地址之间以英文逗号 (,) 隔开。
      graph:["127.0.0.1:3699"]
      meta:["127.0.0.1:45500"]
    }
    # 填写的账号必须拥有 Nebula Graph 相应图空间的写数据权限。
    user: root
    pswd: nebula
    # 填写 Nebula Graph 中需要写入数据的图空间名称。
    space: eureka
    connection {
      timeout: 3000
      retry: 3
    }
    execution {
      retry: 3
    }
    error: {
      max: 32
      output: /tmp/errors
    }
    rate: {
      limit: 64M
      timeout: 1000
    }
  }

  # 处理点数据
  tags: [
    # 设置标签相关信息
    {
    name: movie
    # 设置 Neo4j 数据库服务器地址,String 类型,格式必须为 "bolt://ip:port"。
    server: "bolt://XXX"

    # Neo4j 数据库登录账号和密码。
    user: XXX
    password: XXX

    # 传输是否加密,默认值为 false,表示不加密;设置为 true 时,表示加密。
    encryption: false

    # 设置源数据所在 Neo4j 数据库的名称。如果您使用 Community Edition Neo4j,不支持这个参数。
    # database: graph.db

    type: {
        # 指定数据来源,设置为 neo4j。
        source: neo4j
        # 指定点数据导入 Nebula Graph 的方式,
        # 可以设置为:client(以客户端形式导入)和 sst(以 SST 文件格式导入)。
        # 关于 SST 文件导入配置,参考文档:导入 SST 文件(https://
        # docs.nebula-graph.com.cn/nebula-exchange/
        # use-exchange/ex-ug-import-sst/)。
        sink: client
    }

    # 指定 Nebula Graph Schema 中标签对应的属性名称,以列表形式列出,
    # 与 tags.fields 列表中的属性名称一一对应,形成映射关系,
    # 多个属性名称之间以英文逗号(,)隔开。
    nebula.fields: [released, tagline, title]

    # 指定源数据中与 Nebula Graph 标签对应的属性名称,
    # 以列表形式列出,多个属性名称之间以英文逗号(,)隔开,
    # 列出的属性名称必须与 exec 中列出的属性名称保持一致。
    fields       : [released, tagline, title]

    # 将源数据中某个属性的值作为 Nebula Graph 点 VID 的来源,
    # 如果属性为 int 或者 long 类型,使用 vertex 设置 VID 列。
   # vertex: idInt
    # 如果数据不是 int 类型,则添加 vertex.policy 指定 VID 映射策略,建议设置为 "hash"。
     vertex {
         field: title
         policy: "hash"
    }

    # Spark 的分区数量,默认值为 32。
    partition: 10

    # 单次写入 Nebula Graph 的点数据量,默认值为 256。
    batch: 2000

    # 设置保存导入进度信息的目录,用于断点续传,
    # 如果未设置,表示不启用断点续传。
    check_point_path: "file:///tmp/test"

    # 写入 Cypher 语句,从 Neo4j 数据库中检索打了某种标签的点的属性,并指定别名
    # Cypher 语句不能以英文分号(`;`)结尾。
    exec: "match (n:Movie) return n.released as released, n.tagline as tagline, n.title as title order by n.title"
    }
    # 如果有多个标签,则参考以上说明添加更多的标签相关信息。
  ]

}

配置错误, 要么用上面的vertex:idInd, 要么用下面的 vertex:{}

您好,导入成功了,但是我入了一类节点(vertex),tag是movie,然后主键是 title{string},然后我想查一个title是 Sleepless in Seattle的节点 nGQL请问怎么写? 多谢

FETCH PROP ON movie “Sleepless in Seattle”
可以参考我们的文档 FETCH VERTEX - Nebula Graph Database Manual