个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
30
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Python使用Py2neo创建Neo4j的节点和关系由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
Neo4j是一款开源图数据库，使用Python语言访问Neo4j可以使用Py2neo。本文介绍了使用Py2neo访问Neo4j，批量创建节点和关系的方法。Py2neo提供了直接执行Cypher语句的方法，也提供了诸如Node、Relationship、Path一系列的数据结构，在不同的场景下可以灵活使用.
本文使用的Py2neo是2021.1之后的版本，手册请戳这里： The Py2neo Handbook 。
使用pip安装Py2neo，执行:
|
1
|
pip install py2neo
|
查看已安装的Py2neo是什么版本的:
|
1
|
pip show py2neo
|
本文中会用到多种数据类型，在此一并引用 。
import numpy as np import pandas as pd from py2neo import Node,Relationship,Graph,Path,Subgraph 。
配置Neo4j数据库的访问地址、用户名和密码 。
|
1
2
3
|
neo4j_url =
'访问地址'
user =
'用户名'
pwd
=
'密码'
|
在此时间段之前访问数据库的方式为:
|
1
|
graph
=
Graph(neo4j_url, username
=
user, password
=
pwd)
|
在此时间段之后的版本访问数据库的方式为（就是这么不兼容）:
|
1
|
graph = Graph(neo4j_url, auth=(user,
pwd
))
|
如果熟悉Cypher语句的话，可以通过使用graph.run执行Cypher语句来实现创建节点等操作，方法如下所示:
|
1
2
3
|
cypher_ = "CREATE (:Person {name:
'王王'
, age:35, work:'我}),\
(:Person {name:
'李李'
, age:20, work:'我})"
graph.run(cypher_)
|
这样就在Neo4j中创建了两个label为Person的节点，第一个节点的name属性为“王王”，age属性为35，work属性为“我”，第二个节点的name属性为“李李”，age属性为20，work属性为“宇我”.
同样，可以通过调用graph.run执行Cypher语句创建关系.
|
1
2
3
|
cypher_
=
"MATCH (
from
:Person{name:
'王王'
}),\
(to:Person{name:
'李李'
}) MERGE (
from
)
-
[r:同事]
-
>(to)"
graph.run(cypher_)
|
这样在Neo4j中就有了具有同事关系的两个Person节点.
Py2neo也提供graph.create方法来创建节点和关系 。
|
1
2
|
node
=
Node(
"Person"
, name
=
"李李"
, age
=
20
, work
=
"我"
)
graph.create(node)
|
与执行Cypher语句的效果相同，在Neo4j中创建了一个Person节点.
需要注意的是，这两种创建方法，如果反复执行的话，是会在Neo4j中创建出重复的节点的，即name、age、work属性完全一样，但在Neo4j中的id不一样的多个节点.
上面两种方法都是一次创建一个节点或者一个关系，Py2neo也提供了批量创建节点和关系的方法，而且性能更优。下面就以下图中的图谱为例，使用Py2neo提供Node、Relationship和Subgraph数据结构在Neo4j中创建节点和关系.
首先创建一些label为Person的节点，即Node对象，第一个参数是label，属性按key=value依次作为参数传入。如果节点有多个label，可以用Node.add_label("label_text")来追加label.
|
1
2
3
4
5
6
|
node1
=
Node(
"Person"
, name
=
"王王"
, age
=
35
, work
=
"我"
)
node2
=
Node(
"Person"
, name
=
"李李"
, age
=
20
, work
=
"我"
)
node3
=
Node(
"Person"
, name
=
"张张"
, age
=
30
, work
=
"我"
)
node4
=
Node(
"Person"
, name
=
"赵赵"
, age
=
45
, work
=
"月亮中学"
)
node4.add_label(
"Teacher"
)
node5
=
Node(
"Person"
, name
=
"刘刘"
, age
=
20
, work
=
"地球电子商务公司"
)
|
再创建一些label为Location的节点 。
|
1
2
3
|
node6
=
Node(
"Location"
, name
=
"南京"
)
node7
=
Node(
"Location"
, name
=
"江宁区"
)
node8
=
Node(
"Location"
, name
=
"禄口机场"
)
|
建立一些Person和Person节点之间的关系，Neo4j中的关系是有方向的，所以Relationship第一个参数为起始节点，第三个参数是结束节点，而第二个节点为关系的类型。这里创建的同事、邻居的关系为双向的，老师、学生的关系为单向.
|
1
2
3
4
5
6
7
8
9
10
11
|
relation1
=
Relationship(node1,
"同事"
, node2)
relation2
=
Relationship(node2,
"同事"
, node1)
relation3
=
Relationship(node2,
"同事"
, node3)
relation4
=
Relationship(node3,
"同事"
, node2)
relation5
=
Relationship(node3,
"邻居"
, node4)
relation6
=
Relationship(node4,
"邻居"
, node3)
relation7
=
Relationship(node4,
"学生"
, node5)
relation8
=
Relationship(node5,
"老师"
, node4)
|
创建一些Location和Location节点之间的关系，地域之间的包含关系为单向.
|
1
2
|
relation9
=
Relationship(node6,
"包含"
, node7)
relation10
=
Relationship(node7,
"包含"
, node8)
|
创建Person节点和Location节点之间的关系，这里“到访”的关系是有属性的，date表示到访的日期，stay_hours表示停留的时间。可以使用一个key:value的字典数据结构保存属性，再赋予关系 。
|
1
2
3
4
5
|
properties1
=
{
'date'
:
'2021-7-16'
,
'stay_hours'
:
1
}
relation11
=
Relationship(node2,
"到访"
, node8,
*
*
properties1)
properties2
=
{
'date'
:
'2021-7-19'
,
'stay_hours'
:
4
}
relation12
=
Relationship(node5,
"到访"
, node8,
*
*
properties2)
|
然后将以上所有节点和关系组成Subgraph 。
|
1
2
3
4
5
6
|
node_ls
=
[node1, node2, node3, node4,
node5, node6, node7, node8]
relation_ls
=
[relation1, relation2, relation3, relation4,
relation5, relation6, relation7, relation8,
relation9, relation10, relation11, relation12]
subgraph
=
Subgraph(node_ls, relation_ls)
|
最后通过事务类Transaction提交，批量创建这些节点和关系。这里tx.create并没有真正创建节点和关系，直到graph.commit才一次性提交到Neo4j进行创建.
|
1
2
3
|
tx
=
graph.begin()
tx.create(subgraph)
graph.commit(tx)
|
重复执行上面的命令，不会创造出重复的节点和关系。这一点手册中有说明：“subgraph中的已经和数据库绑定的实体将保持不变，那些没有绑定的将在数据库中新建并绑定上。” 。
create(subgraph) Create remote nodes and relationships that correspond to those in a local subgraph. Any entities in subgraph that are already bound to remote entities will remain unchanged, those which are not will become bound to their newly-created counterparts. 。
做一个简单的实验粗略地对比逐个创建和批量创建的时间开销。在Neo4j为空数据库的情况下，分别采用逐个创建和批量创建的方法创建10000个节点，每个节点有name和age两个属性，都是随机生成的，使用jupyter notebook的%%time命令计算时间开销.
|
1
2
|
import
random
N
=
10000
|
逐个创建节点:
|
1
2
3
4
5
6
7
8
9
|
%
%
time
for
i
in
range
(N):
random_name
=
"P"
+
str
(
round
(random.random()
*
N
*
2
))
random_age
=
round
(random.random()
*
15
)
node
=
Node(
"Person"
, name
=
random_name, age
=
random_age)
graph.create(node)
CPU times: user
50.3
s, sys:
4.19
s, total:
54.5
s
Wall time:
5min
16s
|
批量创建节点:
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
%
%
time
node_ls
=
[]
for
i
in
range
(N):
random_name
=
"P"
+
str
(
round
(random.random()
*
N
*
2
))
random_age
=
round
(random.random()
*
15
)
node
=
Node(
"Person"
, name
=
random_name, age
=
random_age)
node_ls.append(node)
subgraph
=
Subgraph(node_ls, [])
tx
=
graph.begin()
tx.create(subgraph)
graph.commit(tx)
CPU times: user
448
ms, sys:
75.5
ms, total:
523
ms
Wall time:
1.46
s
|
实验中也发现，只是创建节点的话，批量创建方法的时间开销几乎是线性增长的，当一次性提交10万个节点的创建任务时，时间开销大约在4.5秒。 在使用Py2neo构建图谱时，尽可能使用批量创建方法。先创建节点（Node）对象、关系（Relationship）对象，再构成子图（Subgraph），最后利用事务类一次提交创建。 下一篇将介绍如何运用Py2neo查询节点、关系和路径.
这篇关于用Py2neo创建Neo4j的节点、关系及路径的文章就先介绍到这了,更多相关Py2neo内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我！ 。
原文链接：https://segmentfault.com/a/1190000040519140 。
最后此篇关于Python使用Py2neo创建Neo4j的节点和关系的文章就讲到这里了,如果你想了解更多关于Python使用Py2neo创建Neo4j的节点和关系的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
30
4
0
我在网上搜索但没有找到任何合适的文章解释如何使用 javascript 使用 WCF 服务，尤其是 WebScriptEndpoint。 任何人都可以对此给出任何指导吗？ 谢谢 最佳答案 这是一篇关于
我正在编写一个将运行 Linux 命令的 C 程序，例如: cat/etc/passwd | grep 列表 |剪切-c 1-5 我没有任何结果 *这里 parent 等待第一个 child (chi
所以我正在尝试处理文件上传，然后将该文件作为二进制文件存储到数据库中。在我存储它之后，我尝试在给定的 URL 上提供文件。我似乎找不到适合这里的方法。我需要使用数据库，因为我使用 Google 应用引
我正在尝试制作一个宏，将下面的公式添加到单元格中，然后将其拖到整个列中并在 H 列中复制相同的公式 我想在 F 和 H 列中输入公式的数据 Range("F1").formula = "=IF(ISE
问题类似于this one ，但我想使用 OperatorPrecedenceParser 解析带有函数应用程序的表达式在 FParsec . 这是我的 AST: type Expression =
我想通过使用 sequelize 和 node.js 将这个查询更改为代码取决于在哪里 select COUNT(gender) as genderCount from customers where
我正在使用GNU bash，版本5.0.3(1)-发行版(x86_64-pc-linux-gnu)，我想知道为什么简单的赋值语句会出现语法错误: #/bin/bash var1=/tmp
这里，为什么我的代码在 IE 中不起作用。我的代码适用于所有浏览器。没有问题。但是当我在 IE 上运行我的项目时，它发现错误。 而且我的 jquery 类和 insertadjacentHTMl 也不
我正在尝试更改标签的innerHTML。我无权访问该表单，因此无法编辑 HTML。标签具有的唯一标识符是“for”属性。 这是输入和标签的结构:
我有一个页面，我可以在其中返回用户帖子，可以使用一些 jquery 代码对这些帖子进行即时评论，在发布新评论后，我在帖子下插入新评论以及删除 按钮。问题是 Delete 按钮在新插入的元素上不起作用，
我有一个大约有 20 列的“管道分隔”文件。我只想使用 sha1sum 散列第一列，它是一个数字，如帐号，并按原样返回其余列。 使用 awk 或 sed 执行此操作的最佳方法是什么？ Accounti
我需要将以下内容插入到我的表中...我的用户表有五列 id、用户名、密码、名称、条目。 (我还没有提交任何东西到条目中，我稍后会使用 php 来做)但由于某种原因我不断收到这个错误:#1054 - U
所以我试图有一个输入字段，我可以在其中输入任何字符，但然后将输入的值小写，删除任何非字母数字字符，留下“。”而不是空格。 例如，如果我输入: 地球的 70% 是水，-!*#$^^ & 30% 土地 输
我正在尝试做一些我认为非常简单的事情，但出于某种原因我没有得到想要的结果？我是 javascript 的新手，但对 java 有经验，所以我相信我没有使用某种正确的规则。 这是一个获取输入值、检查选择
我想使用 angularjs 从 mysql 数据库加载数据。 这就是应用程序的工作原理；用户登录，他们的用户名存储在 cookie 中。该用户名显示在主页上 我想获取这个值并通过 angularjs
我正在使用 autoLayout，我想在 UITableViewCell 上放置一个 UIlabel，它应该始终位于单元格的右侧和右侧的中心。 这就是我想要实现的目标 所以在这里你可以看到我正在谈论的
我需要与 MySql 等效的 elasticsearch 查询。我的 sql 查询: SELECT DISTINCT t.product_id AS id FROM tbl_sup_price t
我正在实现代码以使用 JSON。 func setup() { if let flickrURL = NSURL(string: "https://api.flickr.com/
我尝试使用for循环声明变量，然后测试cols和rols是否相同。如果是，它将运行递归函数。但是，我在 javascript 中执行 do 时遇到问题。有人可以帮忙吗？ 现在，在比较 col.1 和
我举了一个我正在处理的问题的简短示例。 HTML代码: 1 2 3 CSS 代码: .BB a:hover{ color: #000; } .BB > li:after {
我是一名优秀的程序员,十分优秀！