为了更快地定位、解决问题,麻烦参考下面模版提问 ^ ^
提问参考模版:
- 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"
}
# 如果有多个标签,则参考以上说明添加更多的标签相关信息。
]
}