Contact UsGet started
© 2024 Iron Hive LLC Belgrade

AWS SDK for Go

Written by
Improved by
Updated at September 23, 2024

The AWS SDK for Go is a set of tools for developers working with AWS services in Go.

Getting started

  1. Create a service account.
  2. Assign the service account the roles required for your project. For more information about roles, see the Identity and Access Management documentation.
  3. Create a static access key.

Note

A service account is only allowed to view a list of buckets in the folder it was created in.

A service account can perform actions with objects in buckets that are created in folders different from the service account folder. To enable this, assign the service account roles for the appropriate folder or its bucket.

Installation

To install the AWS SDK for Go, follow the instructions on the vendor's website.

Setup

  1. Go to the ~/.aws/ directory (for macOS and Linux) or C:\Users\<username>\.aws\ (for Windows).

  2. Create a file named credentials with the credentials for Object Storage and copy the following information to it:

    [default]
  aws_access_key_id = <static_key_ID>
  aws_secret_access_key = <secret_key>

  3. Create a file named config with the default region settings and copy the following information to it:

    [default]
  region=ru-central1

    Note

    Some apps designed to work with Amazon S3 do not allow you to specify the region; this is why Object Storage may also accept the us-east-1 value.

To access Object Storage, use the https://storage.yandexcloud.net endpoint.

Code samples

List of bucket names:

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/s3"
)

func main() {

	// Creating a custom endpoint resolver for returning correct URL for S3 storage in the ru-central1 region
	customResolver := aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {
		if service == s3.ServiceID && region == "ru-central1" {
			return aws.Endpoint{
				PartitionID:   "yc",
				URL:           "https://storage.yandexcloud.net",
				SigningRegion: "ru-central1",
			}, nil
		}
		return aws.Endpoint{}, fmt.Errorf("unknown endpoint requested")
	})

	// Loading configuration from ~/.aws/*
	cfg, err := config.LoadDefaultConfig(context.TODO(), config.WithEndpointResolverWithOptions(customResolver))
	if err != nil {
		log.Fatal(err)
	}

	// Creating the S3 client
	client := s3.NewFromConfig(cfg)

	// Getting the list of buckets
	result, err := client.ListBuckets(context.TODO(), &s3.ListBucketsInput{})
	if err != nil {
		log.Fatal(err)
	}

	for _, bucket := range result.Buckets {
		log.Printf("bucket=%s creation time=%s", aws.ToString(bucket.Name), bucket.CreationDate.Format("2006-01-02 15:04:05 Monday"))
	}
}

Getting a list of objects in a bucket:

package main

import (
	"context"
	"fmt"
	"log"
	"flag"

	"github.com/aws/aws-sdk-go-v2/aws"
	"github.com/aws/aws-sdk-go-v2/config"
	"github.com/aws/aws-sdk-go-v2/service/s3"
)

func main() {
	// Getting the bucket name from the command line argument
	bucketName := flag.String("b", "", "The name of the bucket")
	flag.Parse()

	if *bucketName == "" {
		fmt.Println("You must supply the name of a bucket (-b BUCKET)")
		return
	}


	// Creating a custom endpoint resolver for returning the correct URL for S3 storage in the ru-central1 region
	customResolver := aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {
		if service == s3.ServiceID && region == "ru-central1" {
			return aws.Endpoint{
				PartitionID:   "yc",
				URL:           "https://storage.yandexcloud.net",
				SigningRegion: "ru-central1",
			}, nil
		}
		return aws.Endpoint{}, fmt.Errorf("unknown endpoint requested")
	})

	// Loading configuration from ~/.aws/*
	cfg, err := config.LoadDefaultConfig(context.TODO(), config.WithEndpointResolverWithOptions(customResolver))
	if err != nil {
		log.Fatal(err)
	}

	// Creating an S3 client
	client := s3.NewFromConfig(cfg)

	// Getting the list of all files in the bucket
	result, err := client.ListObjectsV2(context.TODO(), &s3.ListObjectsV2Input{
		Bucket: aws.String(*bucketName),
	})
	if err != nil {
		log.Fatal(err)
	}

	for _, object := range result.Contents {
		log.Printf("object=%s size=%d Bytes last modified=%s", aws.ToString(object.Key), object.Size, object.LastModified.Format("2006-01-02 15:04:05 Monday"))
	}
}

See also the code samples and Go SDK API Reference Guide.

Previous
AWS SDK for PHP
Next
GeeseFS