我正在尝试使用连接器从kafka填充neo4j数据库,以便不断创建person节点。如果时间戳相同,我尝试在person节点之间创建一个关系。
MERGE (n:Person{age: event.age, gender:event.gender, glasses:event.glasses })
ON CREATE SET n.id=event.id
WITH (n:Person) as n1, (n:Person) as n2 WHERE n1.event.time = n2.event.time AND n1<>n2
MERGE (n1)-[:was_at {timestamp: event.Time}] –(n2)
从我的json文件发送过来的时间戳的格式如下:2020-10-08t10:29
提前谢谢你的帮助!!
暂无答案!
目前还没有任何答案,快来回答吧!