问题标签 [goblin]

我想在 gremlin 中重复一些遍历，如下所示：

使用goblinpython 包和默认titan11安装（我认为，titan+casssandra+gremlin+elasticsearch，但是，这东西很混乱）。

在 python 中，在做了一些特殊的导入之后，我或多或少地写了与上面完全相同的东西：

（如果您认为可能有帮助，请参阅https://github.com/mikedewar/graphLearning/blob/master/conditional_traversal.py#L107了解所有其他内容）

当我sg使用 goblin 遍历遍历时，我认为来自 gremlin 的 Java 错误：

所以我想它可能不喜欢我传递给它的整数。

请帮忙！我希望能够在 gremlin 中重复内容。

我已将地精 ogm 示例写入我的 spark 应用程序，但我的任务已被破坏，但它正在等待处理！下面是我的代码 def savePartition(p): from goblin import element, properties

rdd = rdd.foreachPartition(savePartition) 我想知道如何关闭上面代码中的响应。非常感谢。

我有 spark 应用程序，它使用 goblin 将数据插入到 Titan 中。但它会插入具有相同名称的重复顶点。测试条件“如果不是结果：”不匹配，我在同一个会话中。

如何解决？多谢。

我是这个名为 Goblin 的 Gremlin 驱动程序的新手。我正在关注Goblin - Async Python toolkit的介绍/教程。如文档中所述，我创建了一个 Python 协程：

当我运行 Python 脚本时，程序似乎陷入了无限循环。此时控制台中既没有显示结果也没有显示错误。

希望任何人都可以帮助我！艾伦

您好，我对 Python 相当陌生，我正在尝试将我在 Flask 上的现有应用程序转换为应该构建在 asyncio 之上的Quart ( https://gitlab.com/pgjones/quart )，所以我可以使用 Goblin OGM 与 JanusGraph 或 TinkerPop 交互。根据我在 Goblin 上找到的示例，我需要获取一个事件循环来异步运行命令。

但是，即使它是建立在 asyncio 之上的，我也找不到从 Quart 获取事件循环的方法。

有谁知道我怎么能得到那个？任何帮助将不胜感激。

我正在尝试一个 Python 应用程序来连接到 Janusgraph 0.2.0。我遵循了所有设置说明，并且能够在图中创建元素并成功遍历它们。

但是，当我尝试从我的应用程序连接并发送 session.flush() 来创建一个元素时，应用程序会冻结并且没有其他任何事情发生。在 gremlin-server.log 我看到以下错误：

1109015 [gremlin-server-worker-1] WARN org.apache.tinkerpop.gremlin.server.handler.WsGremlinBinaryRequestDecoder - Gremlin 服务器没有为请求的 mime 类型 [application/vnd.gremlin-v3.0+json 配置序列化程序] - 默认使用 org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0 1109035 [gremlin-server-worker-1] WARN org.apache.tinkerpop.gremlin.driver.ser.AbstractGraphSONMessageSerializerV1d0 - 请求 [PooledUnsafeDirectByteBuf(ridx: 558 , widx: 558, cap: 592)] 无法被 org.apache.tinkerpop.gremlin.driver.ser.AbstractGraphSONMessageSerializerV1d0 反序列化。1109039 [gremlin-server-worker-1] 警告 org.apache.tinkerpop.gremlin.server.handler.OpSelectorHandler - 请求的 OpProcessor 无效 [null] org.apache.tinkerpop.gremlin.server.op.OpProcessorException：

我在 gremlin-server.yaml 文件中找到了一些关于替换 GraphSON 版本以添加 gremlin-v3.0+json 缺少的序列化程序的信息，我这样做了，但是当我添加时，我收到一个关于不存在的错误能够找到配置的序列化程序类：10348 [main] WARN org.apache.tinkerpop.gremlin.server.AbstractChannelizer - 找不到配置的序列化程序类 - org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV3d0 - 它不会可用 1

所以我的问题是：

1. 有没有一种方法可以将我的应用程序发送到 Gremlin 服务器的序列化程序的版本更改为兼容版本之一
2. 如果我下载 GraphSON 3.0 版并将其放在服务器中，它会工作吗？这意味着我将不得不升级与 Janusgraph 一起打包的 Gremlin Server 的版本，这似乎太多了......

有没有人遇到过类似的问题并有什么建议？

几天来，我一直在用一个 python 应用程序苦苦挣扎，我希望在文件夹中查找一个或多个文件，并遍历每个文件和其中的每条记录，并创建要持久保存在 Janusgraph 数据库中的对象。我正在使用的特定 OGM 要求使用 asyncio 以异步方式完成与数据库的事务。我已经阅读了很多关于 asyncio 的博客和帖子，并且我想我理解 async、await、task 等的概念......在我的应用程序中，我定义了几个处理不同部分的函数：

• 检索所有可用文件的列表
• 选择一个文件进行处理
• 遍历选定的文件并读取一行/记录进行处理
• 接收记录，确定解析 from in 并调用其他几个函数，这些函数负责在将模型对象持久化到数据库之前创建模型对象。例如，我创建了不同的功能：用户、会话、浏览器、设备使用、服务器等......

我理解（我可能是错的）使用 asyncio 的最大优势在于对函数的调用通常会因 I/O、数据库事务、网络延迟等而阻塞的情况......

所以我的问题是我是否需要将我的所有函数转换为协程并安排运行事件循环，或者只是那些会阻塞的函数，比如将事务提交到数据库。我一开始就尝试了这种方法，但遇到了各种各样的问题。

我在我的模式约束中定义了基于一个或多个属性的给定顶点的唯一性。例如：
mgmt.buildIndex('byTenandIdUnique',Vertex.class).addKey(tenantId).unique().buildCompositeIndex()

正如现在预期的那样，当我尝试添加一个已经存在的顶点时，我收到如下错误：

aiogremlin.exception.GremlinServerError: 500: Adding this property for key [tenantId] and value [ACME2_AX2] violates a uniqueness constraint [byTenandIdUnique]

我正在编写一个 Python 应用程序来使用 Goblin OGM 加载日志文件，因此预计数据会重复，并且我不想要同一个 Vertex 的多个实例，因此存在约束。

TinkerPop 或 JanusGraph 有没有办法更新 Vertex 以防它已经存在而不是抛出这个异常？或者这是 OGM 应该处理的事情，或者可能是通过在任何事务之前查询图表来处理代码本身？

我有以下脚本来更新顶点上的属性（janusgraph 0.2.0）。当我从 Gremlin 控制台运行它时，值会按预期更改：

但是，当我使用 gremlin_python(3.2.6) 和 goblin (2.1.0) 在我的 python 代码上粘贴相同的脚本时

airport_runways 属性的值不会更新。关于我可能缺少什么的任何建议？

例如，我似乎找不到任何资源来说明某些流行的 OGM 是否可以与海王星一起使用，而不是编写原始的 gremlin 查询。

你们中的任何人都知道 Neptune 支持或可以使用哪些 OGM，特别是对于 python，您会推荐哪些？

另外，使用 OGM（例如地精）还是坚持使用 gremlin python GVL 会更好吗？