英文:
Insert thousand nodes to neo4j using golang
问题
我正在使用neoism将数据导入到neo4j中，但在导入大数据时遇到了一些问题，导入1000个节点需要8秒。以下是导入100个节点的代码片段。这是一个相当基本的代码，需要改进，有人可以帮助我改进吗？
var wg sync.WaitGroupfor _, itemProps := range items {wg.Add(1)go func(i interface{}) {s := time.Now()cypher := neoism.CypherQuery{Statement: fmt.Sprintf(`CREATE (%v)SET i = {Props}RETURN i`, ItemLabel),Parameters: neoism.Props{"Props": i},}if err := database.ExecuteCypherQuery(cypher); err != nil {utils.Error(fmt.Sprintf("error ImportItemsNeo4j! %v", err))wg.Done()return}utils.Info(fmt.Sprintf("import Item success! took: %v", time.Since(s)))wg.Done()}(itemProps)}wg.Wait()
英文:
I am importing data to neo4j using neoism, and I have some issues importing big data, 1000 nodes, would take 8s. here is a part of the code that imports 100nodes.
quite basic code, needs improvement, anyone can help me improve this?
<!-- language: go -->
var wg sync.WaitGroupfor _, itemProps := range items {wg.Add(1)go func(i interface{}) {s := time.Now()cypher := neoism.CypherQuery{Statement: fmt.Sprintf(`CREATE (%v)SET i = {Props}RETURN i`, ItemLabel),Parameters: neoism.Props{"Props": i},}if err := database.ExecuteCypherQuery(cypher); err != nil {utils.Error(fmt.Sprintf("error ImportItemsNeo4j! %v", err))wg.Done()return}utils.Info(fmt.Sprintf("import Item success! took: %v", time.Since(s)))wg.Done()}(itemProps)}wg.Wait()
答案1
得分: 4
据我所知，Neoism仍在使用旧的API，你应该使用cq代替：https://github.com/go-cq/cq
此外，你应该批量创建节点，
例如，可以在一个请求中发送多个语句，例如每个请求发送100个语句
或者更好的是，将参数列表发送到单个Cypher查询中：
例如，{data} 是一个 [{id:1},{id:2},...] 的列表
UNWIND {data} as propsCREATE (n:Label) SET n = props
英文:
Afaik neoism still uses old APIs, you should use cq instead: https://github.com/go-cq/cq
also you should batch your creates,
i.e. either send multiple statements per request, e.g 100 statements per request
or even better send a list of parameters to a single cypher query:
e.g. {data} is a [{id:1},{id:2},...]
UNWIND {data} as propsCREATE (n:Label) SET n = props
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论