Go を使用して Neptune DB インスタンスに接続する

Go を使用して Neptune に接続するには

1. 空のディレクトリから始めて、新しい Go モジュールを初期化します。

   go mod init example.com/gremlinExample

2. gremlin-go を新しいモジュールの依存関係として追加します。

   go get github.com/apache/tinkerpop/gremlin-go/v3/driver

3. 「gremlinExample.go」という名前のファイルを作成し、テキストエディタで開きます。

4. 以下を gremlinExample.go ファイルにコピーし、(your neptune endpoint) を Neptune DB インスタンスのアドレスに置き換えます。

   package main
   
   import (
     "fmt"
     gremlingo "github.com/apache/tinkerpop/gremlin-go/v3/driver"
   )
   
   func main() {
     // Creating the connection to the server.
     driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection("wss://(your neptune endpoint):8182/gremlin",
       func(settings *gremlingo.DriverRemoteConnectionSettings) {
         settings.TraversalSource = "g"
       })
     if err != nil {
       fmt.Println(err)
       return
     }
     // Cleanup
     defer driverRemoteConnection.Close()
   
     // Creating graph traversal
     g := gremlingo.Traversal_().WithRemote(driverRemoteConnection)
   
     // Perform traversal
     results, err := g.V().Limit(2).ToList()
     if err != nil {
       fmt.Println(err)
       return
     }
     // Print results
     for _, r := range results {
       fmt.Println(r.GetString())
     }
   }
   

   注記

   Neptune TLS 証明書形式は、現在、macOS 搭載の Go 1.18+ ではサポートされていないため、接続を開始しようとすると 509 エラーが発生する可能性があります。ローカルテストでは、インポートに「crypto/tls」を追加し、DriverRemoteConnection 設定を次のように変更することで、これをスキップできます。

   // Creating the connection to the server.
   driverRemoteConnection, err := gremlingo.NewDriverRemoteConnection("wss://your-neptune-endpoint:8182/gremlin",
     func(settings *gremlingo.DriverRemoteConnectionSettings) {
         settings.TraversalSource = "g"
         settings.TlsConfig = &tls.Config{InsecureSkipVerify: true}
     })

5. サンプルを実行するには、次のコマンドを入力します。

   go run gremlinExample.go