我已经使用 gremlin-python 推送数据。现在我想对它运行特定的查询。为此,我正在使用 Gizmo。
我基本上是想达到每个节点的中心度。我怎么做?
目前我已经查询返回与:
g.V().group().
......1> by(id).
......2> by(union(__(), outE('mentions').count()).fold())
我如何做到这一点是:
def query(self, q):
from gizmo import Mapper, Request
from gremlinpy import Gremlin
req = Request('localhost', 8182)
gremlin = Gremlin('g')
mapper = Mapper(request=req, gremlin=gremlin)
# s = mapper.gremlin.V().inE('mentions').count().toList()
# res = mapper.query(gremlin=s)
# print(res.get_data()[0])
print("Something")
res = mapper.query(script=q)
# print(res.get_data()[0])
print("Something")
print(res.data)
print(res.first(), res.data)
# exit(0)
return res.first()
我想要的是显示在res变量中获取的数据。
但是每次我收到错误时:
AttributeError: 'coroutine' object has no attribute 'data'
AttributeError: 'coroutine' object has no attribute 'get_data'
或我尝试的任何类似的东西。
如何获取从协程对象中获取的结果?
注意:我传递给函数 query() 的示例查询是gV().count()
有没有其他更好的方法可以在 gremlin shell 中从 python 运行任何通用查询并获取结果?
图数据库: JanusGraph
后端:卡桑德拉
索引后端: Elasticsearch