任务1:导入历史关注数据
原创小于 1 分钟
# 将之前导出的数据文件follower_0${i}.log拷贝到neo4j的import目录
> cp /var/logs/follower_*.log /home/work/neo4j-community-5.23.0/import
> cd /home/work/neo4j-community-5.23.0
> ./bin/cypher-shell -a neo4j://172.16.185.176:7687 -u root -p 12345678
# 创建索引
neo4j> CREATE CONSTRAINT ON (u:User) ASSERT u.uid IS UNIQUE;
# 逐个导入数据
neo4j> LOAD CSV FROM 'file:///follower_00.log' AS row
MERGE (viewer:User {uid: toString(row[1])})
MERGE (anchor:User {uid: toString(row[2])})
MERGE (viewer) -[:follow]-> (anchor);
neo4j> LOAD CSV FROM 'file:///follower_01.log' AS row
MERGE (viewer:User {uid: toString(row[1])})
MERGE (anchor:User {uid: toString(row[2])})
MERGE (viewer) -[:follow]-> (anchor);
......
neo4j> LOAD CSV FROM 'file:///follower_09.log' AS row
MERGE (viewer:User {uid: toString(row[1])})
MERGE (anchor:User {uid: toString(row[2])})
MERGE (viewer) -[:follow]-> (anchor);
感谢支持
更多内容,请移步《超级个体》。