アクセスキーなしでEC2からS3を使ってみる

# /home/ubuntu

sudo apt update
sudo wget https://go.dev/dl/go1.20.linux-amd64.tar.gz
sudo tar -C /usr/local -xvf go1.20.linux-amd64.tar.gz
export PATH=$PATH:/usr/local/go/bin
source .profile
mkdir app
cd app
go mod init sample
go get github.com/aws/aws-sdk-go-v2/config
go get github.com/aws/aws-sdk-go-v2/service/s3
go get golang.org/x/text/encoding/japanese
go get golang.org/x/text/transform
touch upload.txt #ファイルのアップロードテスト用
touch main.go

package main

import (
	"context"
	"fmt"
	"io/ioutil"
	"os"
	"os/exec"

	"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"
	"golang.org/x/text/encoding/japanese"
	"golang.org/x/text/transform"
)

func main() {
	// リージョンを環境変数に設定
	region, err := exec.Command("sh", "-c", "curl -s http://169.254.169.254/latest/meta-data/placement/availability-zone | sed -e 's/.$//g'").Output()
	if err != nil {
		fmt.Printf("command error:%v", err)
	}
	os.Setenv("AWS_DEFAULT_REGION", string(region))
	// AWSのコンフィグ情報取得
	cfg, err := config.LoadDefaultConfig(context.TODO())
	if err != nil {
		fmt.Printf("config get error:%v", err)
		return
	}
	fmt.Printf("region:%v\n", cfg.Region)
	// s3接続
	s3Client := s3.NewFromConfig(cfg)
	// バケットを一覧表示
	buckets, err := s3Client.ListBuckets(context.TODO(), &s3.ListBucketsInput{})
	if err != nil {
		fmt.Printf("backet display error:%v", err)
		return
	}
	bucketName := ""
	for _, bucket := range (*buckets).Buckets {
		fmt.Printf("Backetname:%s\n", *bucket.Name)
		bucketName = *bucket.Name
	}
	// バケットにファイルをアップロード
	f, err := os.Open("./upload.txt")
	if err != nil {
		fmt.Printf("file open error:%v", err)
		return
	}
	defer f.Close()
	_, err = s3Client.PutObject(context.TODO(), &s3.PutObjectInput{
		Body:   f,
		Bucket: aws.String(bucketName),
		Key:    aws.String("upload-key.txt"),
	})
	if err != nil {
		fmt.Printf("object upload error:%v", err)
		return
	}
	// バケット内のオブジェクトを一覧表示
	objects, err := s3Client.ListObjectsV2(context.TODO(), &s3.ListObjectsV2Input{
		Bucket: aws.String(bucketName),
	})
	if err != nil {
		fmt.Printf("object display error:%v", err)
		return
	}
	for _, object := range objects.Contents {
		fmt.Printf("ObjectName:%v \n", *object.Key)
	}
	// バケットからオブジェクトをダウンロード
	object, err := s3Client.GetObject(context.TODO(), &s3.GetObjectInput{
		Bucket: aws.String(bucketName),
		Key:    aws.String("download.txt"),
	})
	defer object.Body.Close()
	if err != nil {
		fmt.Printf("object download error:%v", err)
		return
	}
	body, err := ioutil.ReadAll(object.Body)
	if err != nil {
		fmt.Printf("object read error:%v", err)
		return
	}
	s, _, _ := transform.String(japanese.ShiftJIS.NewDecoder(), string(body))
	fmt.Printf("downloadText:%v\n", s)
}