Interactive Query with Gremlin¶

Gremlin is one of the most popular query languages in graph databases, as SQL in relational databases. Here, we will give some examples to illustrate how gremlin helps navigate the vertices and edges of a graph.

In [ ]:
# Install graphscope package if you are NOT in the Playground

!pip3 install graphscope


Dataset¶

MODERN, a toy graph from tinkerpop, which consists of 6 vertices and 6 edges. Here are the edges:

[(1,3),(1,2),(1,4),(4,5),(4,3),(6,3)]

In [ ]:
# Import the graphscope module and load the modern graph

import graphscope

graphscope.set_option(show_log=False)  # enable logging


In [ ]:
# Create GIE engine for Gremlin

interactive = graphscope.gremlin(modern_graph)


Between Vertices¶

Traversals between two particular vertices is quite common situations in graph databases. For example, to figure out the relationships between v1 and v2/v3, a gremlin query can be written like this:

In [ ]:
q1 = interactive.execute(
'g.V().has("id", 1).as("u").out().has("id", eq(2).or(eq(3))).as("v").select("u", "v").by("id")'
).all()

for p in q1:
print(p)


Here is an example which is popular in social network scenarios, such as finding common features between two different people, one called "marko" while another called "peter".

In [ ]:
q2 = interactive.execute(
'g.V().has("name", "marko").out().where(__.in().has("name", "peter")).valueMap()'
).all()

for p in q2:
print(p)


Degree Centrality¶

Degree centrality is a measure of the number of edges associated to each vertex, which is of statistical significance in large-scale data processing. Here are some examples:

In [ ]:
q3 = interactive.execute("g.V().group().by().by(bothE().count())").all()
for p in q3:
print(p)

q4 = interactive.execute("g.V().group().by().by(inE().count())").all()
for p in q4:
print(p)


Cycle Detection¶

Cycle detection is another important application of graph query in commerce area where cycles are usually considered as fraudulent patterns. Here is an example illustrating how gremlin helps detect cycles in a graph.

In [ ]:
q5 = interactive.execute(
'g.V().as("u").repeat(out().simplePath()).times(2).where(out().where(eq("u"))).count()'
)
print(q5.one())

In [ ]: