我编写了一个快速脚本,通过Neo4j的遍历框架REST API运行遍历查询:
from py2neo import neo4j
import requests
import json
dbURI = 'http://localhost:7474/db/data/'
def graphTraversal (nodeId):
returnType = 'path'
payload = {
'order': 'breadth_first',
'uniqueness': 'node_global',
'relationships': [{
'direction': 'all',
'type': 'associatedMusicalArtist'
}],
'max_depth': 2
}
payload = json.dumps(payload)
headers = {
'Accept': 'application/json; charset=UTF-8',
'Content-Type': 'application/json'
}
uri = dbURI + '/node/' + nodeId + '/traverse/' + returnType
print '\n> Traversal of ' + uri + ' ...'
res = requests.post(uri, data=payload, headers=headers)
print res.text
return res.json();
def getNodeByUri (db, key, value):
return db.get_indexed_node('nodeIdx', key, value)
def getNodeId (node):
return str(node._id)
def main ():
db = neo4j.GraphDatabaseService(dbURI)
node = getNodeByUri(db, '__URI__', 'http://dbpedia.org/resource/Jimi_Hendrix')
nodeId = getNodeId(node)
rels = graphTraversal(nodeId)
if __name__ == '__main__':
main()
代码运行良好,但我有一个问题:
我知道Java驱动程序允许这样做,但是对于Python来说,文档并不清楚如何做到这一点。在
提前谢谢!在
编辑:这里有一个链接,指向我正在关注的Neo4j's traversal framework REST API文档。在
没有直接的方法可以做到这一点,遍历端点都是单个节点。在
您可以通过使用批处理API来实现,在一个HTTP请求中发送大量遍历请求。看看这里:
http://docs.neo4j.org/chunked/stable/rest-api-batch-ops.html
<然而
对于你正在运行的遍历,你可以很容易地用Cypher来表达它,然后你可以给它多个起点,比如:
然后可以将其发送到事务端点:
http://docs.neo4j.org/chunked/stable/rest-api-transactional.html
相关问题 更多 >
编程相关推荐