GremlinをCosmosDBで使ってみる

#[実践]Graphデータベースフレームワーク ThinkerPopとGremlin

前回記事 Gremlin？GraphDBになぜこのネーミングか。。
↑こちらでさらっとどんなものかをみてみました。

###さて、実際に使ってみましょう。

Microsoftのクラウドサービス、Azure のCosmosDBがサポートしてますので、サクッと作って、サクッと消して、オンプレミスで学習します。

詳しくはこちらのページから。
https://docs.microsoft.com/ja-jp/azure/cosmos-db/create-graph-gremlin-console

Azureのアカウントはございますか？なければ、ローカルにもダウンロードしてきてGremlinコンソールから "bin/gremlin.sh" 　or "bin/gremlin.bat" とするところからは同じですので、
https://www.apache.org/dyn/closer.lua/tinkerpop/3.2.5/apache-tinkerpop-gremlin-console-3.2.5-bin.zip　
をダウンロードして解凍するところからどうぞ。

##1.CosmosDBの作成

Azure PortalからCosmosDBを作成します。

##2.新規Graphの作成

クイックスタートで、Gremlin Consoleのタブからテーブルを作成します。（自分で作成する場合はこちら を参考にしてください。)

##3.データベースエクスプローラーからクエリを実行してみる

データベースエクスプローラーから作成したグラフを確認します。
グレムリンが実行できるテキストフィールドがあるので、これだけでも実行できます。

例に習って、４４歳、トーマスさんを追加します。新しい頂点です。

g.addV('person').property('firstName', 'Thomas').property('lastName', 'Andersen').property('age', 44).property('userid', 1)

できました。
次にメアリーさん。同じ姓なので、奥様でしょうか。

g.addV('person').property('firstName', 'Mary Kay').property('lastName', 'Andersen').property('age', 39).property('userid', 2)

ロビンとベン。これで四人入りました。

g.addV('person').property('firstName', 'Robin').property('lastName', 'Wakefield').property('userid', 3)
g.addV('person').property('firstName', 'Ben').property('lastName', 'Miller').property('userid', 4)

４０歳以上の人を探してみます。

g.V().hasLabel('person').has('age', gt(40))

トーマスだけですね。has　または　haslabel　はもちろん、ラベルがないと検索できませんが、全てにラベルがなくてもエラーにはなりません。

g.V().hasLabel('person').values('firstName')

valuesで結果の特定のプロパティを投影できます。これをプロジェクションと呼ぶらしいです。大げさな感じですが。。名前がなんとかさん、とか、そういう風に探すのもSQLでは当たり前でしたね。

次は頂点同士の辺を入力します。トーマスとメアリーは知り合い程度だったようです。

g.V().hasLabel('person').has('firstName', 'Thomas').addE('knows').to(g.V().hasLabel('person').has('firstName', 'Mary Kay'))

これはコンソールからしないとダメなようです。データベースエクスプローラーのベータ版では動きませんでした。ベータ版なので今のところ。といった感じです。

友達の友達を探したり、orやand　先ほどのプロジェクションで、どんどん複雑なクエリができます。

	Gremlin のステップ
addE	2 つの頂点の間に辺を追加します。
addV	グラフに頂点を追加します。
and	すべてのトラバーサルが値を返すようにします。
as	ステップの出力に変数を割り当てるステップ モジュレーター。
by	group および order と共に使用するステップ モジュレーター。
coalesce	結果を返す最初のトラバーサルを返します。
constant	定数値を返します。 coalesce と共に使用します。
count	トラバーサルからカウントを返します。
dedup	重複を削除して値を返します。
drop	値 (頂点/辺) を破棄します。
fold	結果の集計を計算するバリアとして機能します。
group	指定されたラベルに基づいて値をグループ化します。
has	プロパティ、頂点、辺をフィルター処理するときに使用します。 hasLabel、hasId、hasNot、has の各バリアントをサポートします。
inject	値をストリームに挿入します。
is	ブール式を使用してフィルターを実行するときに使用します。
limit	トラバーサルで項目の数を制限するときに使用します。
local	サブクエリと同様に、トラバーサルのセクションをローカルでラップします。
not	フィルターの否定を生成するときに使用します。
optional	指定されたトラバーサルの結果が生成された場合は、その結果を返します。それ以外の場合は、呼び出し元の要素を返します。
or	少なくとも 1 つのトラバーサルで値が返されるようにします。
order	指定された並べ替え順序で結果を返します。
path	トラバーサルの完全なパスを返します。
project	プロパティをマップとして投影します。
properties	指定されたラベルのプロパティを返します。
range	値の指定された範囲にフィルターを適用します。
repeat	ステップを指定された回数繰り返します。 ループに使用します。
sample	トラバーサルの結果をサンプリングするときに使用します。
select	トラバーサルの結果を予想するときに使用します。
store	トラバーサルの非ブロッキング集計に使用します。
tree	頂点からのパスを集計してツリーを形成します。
unfold	反復子をステップとしてアンロールします。
union	複数のトラバーサルの結果をマージします。
V	頂点および辺の間でのトラバーサルに必要なステップ (V、E、out、in、both、outE、inE、bothE、outV、inV、bothV、otherV) が含まれています。
where	トラバーサルの結果をフィルター処理するときに使用します。 eq、neq、lt、lte、gt、gte、between の各演算子をサポートします。

##4.削除

チュートリアルですので、満足したらすぐに作ったデータベースは消しておきましょうね。

##まとめ
初期の値が１０Gというやる気を見せているので当然、相当数を高速にこなす分散データベースですので、この後はインポートや、エクスポートで他のデータベースやスキーマに移動したりをスキルアップしていきましょう！
Cosmos+GraphDBの適している使い方として、ソーシャルや、ゲームなどリアルタイムな関係性をAPIを介して情報のやりとりをするようなユースケースが考えられますね。