有条件地中断java-gremlin更新遍历，有错误信息

Question

我有一个场景，我在更新遍历过程中想要检查一个条件，如果该条件为假，我想中断遍历并保持图形不变。另外我想知道遍历被跳过，所以我可以向调用代码抛出异常。

约束：

我需要在一次遍历中完成此操作，因为我使用的图形数据库服务无法在多次遍历中保存事务。

我确实需要一种方法来确定遍历被中断的原因。

此外，我似乎无法使用 sideEffect() 步骤 (?)，因为这似乎与 gremlin 查询的序列化无关。

主要穿越的作品在本地使用TinkerGraph而不是部署为拉姆达invocing AWS海王星。

GraphTraversalSource g = graph.traversal();

g.V().hasLabel("ops").fold()

  .coalesce(

      unfold(),

      sideEffect(t -> { throw new RuntimeException("First vertice not found"); }))

  .as("a")

  // do much more stuff

  .hasNext();

sideEffect(org.someone.graph.ClassImpl$$Lambda$155/352598575@1b7f1140)]]，aliases={g=g}}}] 无法被 org.apache.tinkerpop.gremlin.driver.ser.AbstractGryoMessageSerializerV3d0 序列化。

Answer 1

Lambda 无法序列化，这就是您收到该异常的原因。此外，Neptune 不支持lambda ，因此您的方法无论如何都行不通。您使用 TinkerGraph 进行的实验之所以有效，是因为它没有任何这些限制。我不确定你能做些什么来解决这个问题，因为你提到了：我确实需要一种方法来确定遍历被中断的原因。也许你可以constant()以某种方式使用？gremlin> g = TinkerFactory.createModern().traversal()==>graphtraversalsource[tinkergraph[vertices:6 edges:6], standard]gremlin> g.V().has('person','name','marko').fold().coalesce(unfold(), constant('Not Found'))==>v[1]gremlin> g.V().has('person','name','x').fold().coalesce(unfold(), constant('Not Found'))==>Not Found我不确定这是否会完美运行，因为你想保持图形不变根据您编写 Gremlin 的方式，这在 TinkerGraph 中甚至行不通。constant()不是将被识别为回滚事务的方法的“错误条件”。也许这只是需要注意的事情。根据您的逻辑的复杂程度，您最终可能会得到一些非常难以阅读的 Gremlin。您可能需要重新考虑您的方法。