Goblin, or Goblin OGM (Object Graph Mapper), is a Python library that adds support for asynchronous programming for the Gremlin Server platform. Use this tag for questions about implementing Goblin or working with it.
Questions tagged [goblin]
12 questions
6
votes
1 answer
asyncio - how many coroutines?
I have been struggling for a few days now with a python application where I am expecting to look for a file or files in a folder and iterate through the each file and each record in it and create objects to be persisted on a Janusgraph database. The…
Cracoras
- 347
- 3
- 16
5
votes
1 answer
How to obtain an event loop from Quart
Hello I fairly new to Python and I am trying to convert an existing application I have on Flask into Quart (https://gitlab.com/pgjones/quart) which is supposed to be built on top of asyncio, so I can use Goblin OGM to interact with JanusGraph or…
Cracoras
- 347
- 3
- 16
2
votes
1 answer
Using an OGM with AWS Neptune
I can't seem to find any resources that state whether or not some popular OGMs can be used with neptune instead of writing raw gremlin queries for example.
Would any of you know what OGMs are supported or can be used with Neptune and which would you…
new-dev-123
- 361
- 1
- 6
2
votes
1 answer
passing numbers into gremlin via goblin in python
I'd like to repeat a bit of a traversal in gremlin, like this:
g.V(1).repeat(out()).times(1)
using the goblin package for python, and the default titan11 install (which is, I think, titan+casssandra+gremlin+elasticsearch but, well, this stuff is…
Mike Dewar
- 10,945
- 14
- 49
- 65
1
vote
1 answer
Connecting to Neptune using aiogremlin
I am trying to connect to AWS Neptune using aiogremlin but keep getting SSL certificate errors. I tried using 3 different certificates downloaded from Amazon Trust Repository but none of them work. With AmazonRootCA1.pem and SFSRootCAG2.pem I keep…
shreyansh
- 97
- 8
1
vote
1 answer
Janusgraph/TinkerPop - Constraint violation - How to add or update an existing Vertex
I have defined in my schema constraints to ensure uniqueness of given vertices based one or more properties. For example:
mgmt.buildIndex('byTenandIdUnique',Vertex.class).addKey(tenantId).unique().buildCompositeIndex()
As expected now, when I try to…
Cracoras
- 347
- 3
- 16
1
vote
1 answer
Goblin gets 'WSServerHandshakeError'
I'm new to this Gremlin-driver called Goblin. I was following the introduction/tutorial on Goblin - Async Python toolkit.
As described in the documentation, I created a Python coroutine:
loop = asyncio.get_event_loop()
app =…
Alan Wang
- 11
- 2
1
vote
0 answers
Task was destroyed but it is pending! in my spark app
i have wrote goblin ogm sample into my spark app, but i got Task was destroyed but it is pending!
below is my code
def savePartition(p):
from goblin import element, properties
class Brand(element.Vertex):
name =…
softwarevamp
- 827
- 10
- 14
0
votes
0 answers
Storing ELF file contents together with parsed goblin representation (self referential structs)
in one of my rust projects I would like to store an the contents of an ELF file in a structure together with its parsed representation created by the goblin crate:
struct AnalysisFile<'a> {
filename: String,
content: Vec,
elf_info:…
flammi88
- 381
- 2
- 14
0
votes
1 answer
Vertex property gets changed from Gremlin Console but not from Python script
I have the following script to update a property on a vertex (janusgraph 0.2.0). When I run it from the Gremlin Console the value gets changed as…
Cracoras
- 347
- 3
- 16
0
votes
1 answer
How to change version of Goblin OGM Serializer for Janusgraph (TinkerPop 3.2.6) #101
I am trying out a Python application to connect to a Janusgraph 0.2.0. I followed all the setup instructions and I am able to create elements in the graph and traverse them successfully.
import asyncio
from goblin import Goblin
from quart import…
Cracoras
- 347
- 3
- 16
0
votes
1 answer
How to prevent titan generate duplicate records with same property?
i have spark app which insert data into titan with goblin. but it insert duplicate vertexes with same name. the test condition 'if not result:' not match, and i am in the same session.
def savePartition(p):
print ('savePartition', p)
from…
softwarevamp
- 827
- 10
- 14