importcsvfrompy2neoimportGraph,Node,Relationship,NodeMatcherdefaa():g=Graph('http://localhost:7474',user='neo4j',password='HTL123123',name='neo4j')#连接neo4j，将'xxx'分别修改为你的用户名和密码#g.delete_all()#清除neo4j中原有节点等所有信息withopen('C:/Users/h1531/Desktop/tea.csv','r',encoding='gbk')asf:reader=csv.reader(f)foriteminreader:#ifreader.line_num==1:#continueprint("当前行号：",reader.line_num,"当前内容：",item)start_node=Node("供应商名称",name=item[0])end_node=Node("属性值",value=item[2])relation=Relationship(start_node,item[1],end_node)g.merge(start_node,"供应商名称","名称")g.merge(end_node,"属性值","value")g.merge(relation,"产品总量","属性")if__name__=='__main__':aa()
