Gremlin で Amazon Neptune をクエリする

1
%%gremlin
2
// Drop existing data
3
g.V().drop()

1
%%gremlin
2
// Add Vertices
3
g.addV('person').property(id, 'A').property('age', 30)
4
 .addV('person').property(id, 'B').property('age', 25)
5
 .addV('person').property(id, 'C').property('age', 35)
6
 .addV('person').property(id, 'D').property('age', 20)
7
 .addV('person').property(id, 'E').property('age', 18)
8
 .addV('person').property(id, 'F').property('age', 25)
9
 .addV('person').property(id, 'G').property('age', 10)
10
 .addV('person').property(id, 'H').property('age', 15)

1
%%gremlin
2
// Add Edges
3
g.V('A').addE('know').to(g.V('B')).property('weight', 1.0)
4
 .V('A').addE('know').to(g.V('C')).property('weight', 0.9)
5
 .V('A').addE('know').to(g.V('H')).property('weight', 0.5)
6
 .V('B').addE('know').to(g.V('D')).property('weight', 0.8)
7
 .V('B').addE('know').to(g.V('E')).property('weight', 0.4)
8
 .V('C').addE('know').to(g.V('F')).property('weight', 0.5)
9
 .V('C').addE('know').to(g.V('G')).property('weight', 0.6)
10
 .V('D').addE('know').to(g.V('E')).property('weight', 0.7)
11
 .V('H').addE('know').to(g.V('E')).property('weight', 1.0)
12
 .V('H').addE('know').to(g.V('G')).property('weight', 1.0)

1
%%gremlin
2
// Extract Vertices
3
g.V()
4
 .project('id', 'properties') // Projection
5
 .by(id()).by(valueMap()) // valueMap returns properties of vertices.

1
%%gremlin
2
// Extract persons (entities) which are older than 25 years old and connected from A up to 2nd.
3
g.V('A')
4
 .repeat(outE().inV()).times(2).emit() // Repeat traversal of adjacent vertices twice
5
 .has('age', gte(25)) // Greater than or equal 25 years old
6
 .project('id', 'age')
7
 .by(id()).by(values('age'))

1
%%gremlin
2
// Start traversal at A which extracts vertices that have a multiplied weight value greater than 0.5
3
g.withSack(1.0f).V('A') // Sack can be used to store temporary data
4
 // Multiply a weight value of an out-directed edge by a sack value, and traverse all in-directed vertices
5
 .repeat(outE().sack(mult).by('weight').inV().simplePath()).emit()
6
 .where(sack().is(gt(0.5))) // A sack value greater than 0.5
7
 .dedup() // deduplication
8
 .project('id', 'weight')
9
 .by(id).by(sack())

1
%%gremlin -d T.id -de weight
2
// -d specifies the vertex property to display
3
// -de specifies the edge property to display
4

5
// Execute traversal from example 3
6
g.withSack(1.0f).V('A') // Sack is used to store temporary data
7
 .repeat(outE().sack(mult).by('weight').inV().simplePath()).emit() // Traverse with edge weight
8
 .where(sack().is(gt(0.5))) // Filter paths where the sack value > 0.5
9
 .dedup() // Remove duplicate paths
10
 .path() // Extract path data
11
 .by(elementMap()) // Display properties of vertices and edges