问题描述
g
.V("user-11")
.repeat(bothE().subgraph("subGraph").outV())
.times(2)
.cap("subGraph")
.next()
当我使用 gremlin-python
运行它时,我收到以下响应:
{'@type': 'tinker:graph','@value': {'vertices': [v[device-3],v[device-1],v[user-11],v[card-1]],'edges': [e[68bad734-db2b-bffc-3e17-a0813d2670cc][user-11-uses_device->device-1],e[14bad735-2b70-860f-705f-4c0b769a7849][user-11-uses_device->device-3],e[f0bb3b6d-d161-ec60-5e6d-068272297f24][user-11-uses_card->card-1]]}}
这是查询获得的子图的Graphson表示。
我想使用 Java 和 gremlin-driver
获得相同的响应,但我不知道如何。
我最好的尝试是:
ObjectMapper mapper = GraphSONMapper.build().version(GraphSONVersion.V3_0).create().createMapper();
Object a = graphTraversalSource
.V(nodeId)
.repeat(bothE().subgraph("subGraph").outV())
.times(2)
.cap("subGraph")
.next();
return mapper.writeValueAsstring(a);
但这给了我以下错误:
io.netty.handler.codec.DecoderException: org.apache.tinkerpop.gremlin.driver.ser.SerializationException: org.apache.tinkerpop.shaded.kryo.KryoException: Encountered unregistered class ID: 65536
我正在使用 AWS Neptune,但鉴于我通过 gremlin-python
收到我想要的答案,我怀疑这是否会产生影响。
感谢您提供的任何帮助!谢谢
解决方法
如评论中所述
- 当使用 Java 时,你得到的将是一个实际的 TinkerGraph
- 建议使用 GraphBinary 或 GraphSONV3D0 序列化程序。
陀螺仪较旧,如果您未指定其他序列化程序之一,则可能会导致您看到的错误。
请注意,即使您使用其他序列化程序之一,要将图形反序列化为 JSON,您也需要使用特定的 TinkerGraph 序列化程序(示例见本答案末尾)。否则你只会得到 {}
返回。
但是,在 Java Gremlin 客户端的情况下,您可能根本不需要生成 JSON ....
如果你有一个实际的 TinkerGraph,你可以对内存中的子图运行真正的 Gremlin 查询——只需为它创建一个新的遍历源。如果您愿意,您还可以使用 graph.io
类将图形写入文件。 TinkerGraph 将包括属性以及边和顶点。
您也可以使用诸如
之类的语句直接访问 TinkerGraph 对象a.vertices
和 a.edges
通过一个具体的例子,如果你有一个表单查询
TinkerGraph tg = (TinkerGraph)g.V().bothE().subgraph("sg").cap("sg").next();
然后你就可以了
GraphTraversalSource g2 = tg.traversal();
Long cv = g2.V().count().next();
Long ce = g2.E().count().next();
或者您可以直接使用以下形式的语句访问 TinkerGraph 数据结构:
Vertex v = tg.vertices[<some-id>]
或
List properties = tg.vertices[<some-id>].properties()
这实际上意味着在处理子图时,您可以在 Java 客户端中获得更多功能。
如果您仍然觉得您需要子图的 JSON 版本,IO 参考是一个方便的书签:https://tinkerpop.apache.org/docs/3.4.9/dev/io/#_io_reference
已编辑:-为了节省您大量阅读文档的时间,此代码会将 TinkerGraph 打印为 JSON
mapper = GraphSONMapper.build().
addRegistry(TinkerIoRegistryV3d0.instance()).
version(GraphSONVersion.V3_0).create().createMapper();
mapper.writeValueAsString(tg)