problem with AWS neptuneDB Golang GremlinGo

I am working with neptuneDB AWS. I want to test locally on my Ubuntu. I wrote some code for that but it's not working. Although I've secret credentials. I want to write and test the basic crud with Gremlin locally. I want to write and test the basic crud with Gremlin locally. But I can't and doesn't fix this code. this is my code sample

   package main
import (
"context"
"fmt"
"log"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/config"
"github.com/aws/aws-sdk-go-v2/service/neptune"
"github.com/aws/aws-sdk-go-v2/service/neptune/types"
"github.com/aws/aws-sdk-go-v2/aws/credentials"
)
const (
ACCESS_KEY = "YOUR_ACCESS_KEY"
SECRET_KEY = "YOUR_SECRET_KEY"
)
func main() {
cfg, err := config.LoadDefaultConfig(context.TODO(),
config.WithRegion("us-west-2"),
config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider(ACCESS_KEY, SECRET_KEY, "")),
)
if err != nil {
log.Fatal("failed to load AWS config", err)
}
svc := neptune.NewFromConfig(cfg)
// Insert data
err = insertData(svc)
if err != nil {
log.Fatal("failed to insert data", err)
}
fmt.Println("Data inserted successfully")
// Update data
err = updateData(svc)
if err != nil {
log.Fatal("failed to update data", err)
}
fmt.Println("Data updated successfully")
// Delete data
err = deleteData(svc)
if err != nil {
log.Fatal("failed to delete data", err)
}
fmt.Println("Data deleted successfully")
// Read data
_, err = readData(svc)
if err != nil {
log.Fatal("failed to read data", err)
}
fmt.Println("Data read successfully")
}
// Insert data
func insertData(svc *neptune.Client) error {
query := "g.addV('Person').property('name', 'John').property('age', 30).property('em', 'eer')"
_, err := executeGremlinQuery(svc, query)
return err
}
// Update data
func updateData(svc *neptune.Client) error {
query := "g.V().has('name', 'John').property('age', 31)"
_, err := executeGremlinQuery(svc, query)
return err
}
// Delete data
func deleteData(svc *neptune.Client) error {
query := "g.V().has('name', 'John').drop()"
_, err := executeGremlinQuery(svc, query)
return err
}
// Read data
func readData(svc *neptune.Client) ([]byte, error) {
query := "g.V().has('name', 'John')"
result, err := executeGremlinQuery(svc, query)
if err != nil {
return nil, err
}
fmt.Println("Result:", result)
return result, nil
}
// Execute a Gremlin query
func executeGremlinQuery(svc *neptune.Client, query string) ([]byte, error) {
input := &types.ExecuteStatementInput{
GremlinQueryString: &query,
}
output, err := svc.ExecuteStatement(context.TODO(), input)
if err != nil {
return nil, err
}
return output.Items[0].Properties["value"].Value.([]byte), nil
}

If you trying to connect to Neptune using Go, the recommended way is to use the gremlin-go driver instead of the aws-sdk-go (see Neptune docs here).

Additional gremlin-go information can be found in the TinkerPop reference docs. Note that gremlin-go has slightly different step syntax to match the Go language, if you'd like to submit scripts using Groovy syntax instead, see instructions here.

If you are trying to use SigV4 signing to connect to IAM database using gremlin-go, you can follow the answers that Kelvin linked.

Hope this helps.