AWS SDK for Go (aws-sdk-go) 使用指南

AWS SDK for Go (aws-sdk-go) 是 AWS 官方提供的 Go 语言开发工具包，用于与 AWS 云服务进行交互。下面我将介绍其基本用法和常见示例。

安装和配置

首先安装 SDK：

go get github.com/aws/aws-sdk-go

基本配置

package main

import (
	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/aws/session"
	"github.com/aws/aws-sdk-go/aws/credentials"
)

func main() {
	// 1. 使用默认配置（从环境变量或~/.aws/credentials读取）
	sess := session.Must(session.NewSessionWithOptions(session.Options{
		SharedConfigState: session.SharedConfigEnable,
	}))

	// 2. 显式指定凭证和区域
	sess := session.Must(session.NewSession(&aws.Config{
		Region:      aws.String("us-west-2"),
		Credentials: credentials.NewStaticCredentials("AKID", "SECRET_KEY", "TOKEN"),
	}))
}

常用服务示例

1. S3 服务操作

import (
	"github.com/aws/aws-sdk-go/service/s3"
	"log"
)

func s3Example() {
	sess := session.Must(session.NewSession(&aws.Config{
		Region: aws.String("us-west-2"),
	}))

	svc := s3.New(sess)

	// 列出所有bucket
	result, err := svc.ListBuckets(nil)
	if err != nil {
		log.Fatal(err)
	}

	for _, b := range result.Buckets {
		log.Printf("* %s created on %s\n",
			aws.StringValue(b.Name), aws.TimeValue(b.CreationDate))
	}

	// 上传文件
	file, err := os.Open("testfile.txt")
	if err != nil {
		log.Fatal(err)
	}
	defer file.Close()

	_, err = svc.PutObject(&s3.PutObjectInput{
		Bucket: aws.String("my-bucket"),
		Key:    aws.String("testfile.txt"),
		Body:   file,
	})
	if err != nil {
		log.Fatal(err)
	}
}

2. EC2 服务操作

import "github.com/aws/aws-sdk-go/service/ec2"

func ec2Example() {
	sess := session.Must(session.NewSession(&aws.Config{
		Region: aws.String("us-west-2"),
	}))

	svc := ec2.New(sess)

	// 列出所有实例
	result, err := svc.DescribeInstances(nil)
	if err != nil {
		log.Fatal(err)
	}

	for _, r := range result.Reservations {
		for _, i := range r.Instances {
			log.Printf("Instance ID: %s, State: %s\n",
				aws.StringValue(i.InstanceId), 
				aws.StringValue(i.State.Name))
		}
	}

	// 启动新实例
	runResult, err := svc.RunInstances(&ec2.RunInstancesInput{
		ImageId:      aws.String("ami-e7527ed7"),
		InstanceType: aws.String("t2.micro"),
		MinCount:     aws.Int64(1),
		MaxCount:     aws.Int64(1),
	})
	if err != nil {
		log.Fatal(err)
	}
	log.Println("Created instance:", *runResult.Instances[0].InstanceId)
}

3. DynamoDB 操作

import "github.com/aws/aws-sdk-go/service/dynamodb"

func dynamoExample() {
	sess := session.Must(session.NewSession(&aws.Config{
		Region: aws.String("us-west-2"),
	}))

	svc := dynamodb.New(sess)

	// 创建表
	input := &dynamodb.CreateTableInput{
		AttributeDefinitions: []*dynamodb.AttributeDefinition{
			{
				AttributeName: aws.String("UserId"),
				AttributeType: aws.String("N"),
			},
		},
		KeySchema: []*dynamodb.KeySchemaElement{
			{
				AttributeName: aws.String("UserId"),
				KeyType:       aws.String("HASH"),
			},
		},
		ProvisionedThroughput: &dynamodb.ProvisionedThroughput{
			ReadCapacityUnits:  aws.Int64(10),
			WriteCapacityUnits: aws.Int64(10),
		},
		TableName: aws.String("Users"),
	}

	_, err := svc.CreateTable(input)
	if err != nil {
		log.Fatal(err)
	}

	// 插入数据
	_, err = svc.PutItem(&dynamodb.PutItemInput{
		TableName: aws.String("Users"),
		Item: map[string]*dynamodb.AttributeValue{
			"UserId": {
				N: aws.String("1"),
			},
			"UserName": {
				S: aws.String("John Doe"),
			},
		},
	})
	if err != nil {
		log.Fatal(err)
	}
}

错误处理

AWS SDK 返回的错误通常包含丰富的信息：

result, err := svc.SomeAPICall(input)
if err != nil {
    if aerr, ok := err.(awserr.Error); ok {
        switch aerr.Code() {
        case s3.ErrCodeNoSuchBucket:
            // 处理特定错误
        default:
            log.Println(aerr.Error())
        }
    } else {
        // 非AWS错误
        log.Println(err.Error())
    }
    return
}

最佳实践

1. 复用 Session：Session 创建开销较大，应该在应用生命周期内复用
2. 配置超时：为 HTTP 客户端配置合理的超时
3. 使用 Context：支持上下文传递以控制超时和取消
4. 处理分页：对于返回大量数据的 API 使用分页

// 带上下文的调用示例
ctx := context.Background()
ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
defer cancel()

result, err := svc.SomeAPICallWithContext(ctx, input)

AWS SDK for Go 提供了完整的 AWS 服务 API 覆盖，以上只是基础示例。实际开发中应参考 官方文档 获取各服务的详细 API 说明。