MySQL에서 neo4j에 큰 데이터 세트 삽입

Question

py2neo (v 3.1.2)와 함께 python 3을 사용하여 MySQL에서 많은 양의 데이터를 Neo4j에 삽입하고 있습니다. MySQL의 테이블에는 약 2 천만 개의 행이 있습니다. neo4j의 웹 사이트에서 제안한대로 MySQL 데이터를 CSV으로 변환하지 않고 삽입하고 싶습니다.

transaction=graph_db.begin() 
sql="SELECT id FROM users" 
cursor.execute(sql) 
user_data=cursor.fetchall() 
count=1 
for row in user_data: 
    user_node=Node("User",user_id=row[0]) 
    transaction.create(user_node) 
    if count%10000==0: 
     transaction.commit() 
    count=count+1 

목표는 10000의 일괄 삽입했다 그러나 트랜잭션은 첫 번째 반복 (10K의 배치의 첫 번째 삽입) 후 고장 :

내 코드는 다음과 같습니다. 다음은 오류입니다.

raise TransactionFinished(self) 
py2neo.database.TransactionFinished: <py2neo.database.BoltTransaction object at 0x104e36588> 

누군가이 오류의 의미와이 문제를 해결하는 방법을 설명 할 수 있습니까?

Answer 1

나는 파이썬 모르지만, 문제는 사이클에서 트랜잭션을 커밋 열지 않는 점이다 :

sql="SELECT id FROM users" 
cursor.execute(sql) 
user_data=cursor.fetchall() 
count=1 
for row in user_data: 
    if count%10000==1: 
     transaction=graph_db.begin() 
    user_node=Node("User",user_id=row[0]) 
    transaction.create(user_node) 
    if (count%10000==0) or (count==len(user_data)): 
     transaction.commit() 
    count=count+1