Using Graph (GLV)

Goblin provides access to the underlying aiogremlin asynchronous version of the Gremlin-Python Gremlin Language Variant (GLV) that is bundled with Apache TinkerPop beginning with the 3.2.2 release. Traversals are generated using the class Graph combined with a remote connection class, either DriverRemoteConnection:

>>> import asyncio
>>> import goblin  # provides aliases to common aiogremlin objects

>>> loop = asyncio.get_event_loop()
>>> remote_conn = loop.run_until_complete(
...     goblin.DriverRemoteConnection.open(
...         "http://localhost:8182/gremlin", 'g'))
>>> graph = goblin.driver.Graph()
>>> g = graph.traversal().withRemote(remote_conn)

Once you have a traversal source, it’s all Gremlin…:

>>> traversal = g.addV('query_language').property('name', 'gremlin')

traversal is in an instance of AsyncGraphTraversal, which implements the Python 3.5 asynchronous iterator protocol:

>>> async def iterate_traversal(traversal):
...     async for msg in traversal:
...         print(msg)

>>> loop.run_until_complete(iterate_traversal(traversal))
v[...]

AsyncGraphTraversal also provides several convenience coroutine methods to help iterate over results:

• next
• toList
• toSet

Notice the mixedCase? Not very pythonic? Well no, but it maintains continuity with the Gremlin query language, and that’s what the GLV is all about…

Note: Gremlin steps that are reserved words in Python, like or, in, use a a trailing underscore or_ and in_.

The Side Effect Interface

When using TinkerPop 3.2.2+ with the default Goblin provides an asynchronous side effects interface using the AsyncRemoteTraversalSideEffects class. This allows side effects to be retrieved after executing the traversal:

>>> traversal = g.V().aggregate('a')
>>> loop.run_until_complete(traversal.iterate())
[['V'], ['aggregate', 'a']]

Calling keys will return an asynchronous iterator containing all keys for cached side effects:

>>> async def get_side_effect_keys(traversal):
...     keys = await traversal.side_effects.keys()
...     print(keys)

>>> loop.run_until_complete(get_side_effect_keys(traversal))
{'a'}

Then calling get using a valid key will return the cached side effects:

>>> async def get_side_effects(traversal):
...     se = await traversal.side_effects.get('a')
...     print(se)


>>> loop.run_until_complete(get_side_effects(traversal))
{v[1]: 1, ...}

And that’s it! For more information on Gremlin Language Variants, please visit the Apache TinkerPop GLV Documentation.