私はを使用してneo4jにデータをインポートしていますがneoism、ビッグデータ（1000ノード）のインポートに8秒かかる問題がいくつかあります。これは100ノードをインポートするコードの一部です。非常に基本的なコード、改善が必要、誰でも私がこれを改善するのを助けることができますか？
var wg sync.WaitGroup
for _, 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()
Afaik neoismはまだ古いAPIを使用しています。代わりにcqを使用してください：https : //github.com/go-cq/cq
また、作成したものをバッチ処理する必要があります。
つまり、リクエストごとに複数のステートメントを送信します（例：リクエストごとに100ステートメント）
または、さらに優れた方法として、パラメータのリストを単一の暗号クエリに送信します。
たとえば{data}は [{id:1},{id:2},...]
UNWIND {data} as props
CREATE (n:Label) SET n = props
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加