使用 Go 连接到 Neptune 数据库实例

使用 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 数据库实例的地址：

   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())
     }
   }
   

   注意

   搭载 macOS 的 Go 1.18+ 目前不支持 Neptune TLS 证书格式，尝试启动连接时可能会出现 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