aws s3 go sdk 使用

引入包

"github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/credentials" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/s3"

創建 session

func newSession() (*session.Session, error){creds := credentials.NewStaticCredentials(ak, sk, "")config := &aws.Config{Region: aws.String(region), Endpoint: &endpoint, S3ForcePathStyle: aws.Bool(true), Credentials: creds, DisableSSL: &disableSSL, }return session.NewSession(config) }

創建 bucket

sess, err := newSession() if err != nil {fmt.Println("failed to create session,", err)return } svc := s3.New(sess)params := &s3.CreateBucketInput{Bucket: aws.String(bucket), } _, err = svc.CreateBucket(params)

列出所有 bucket

sess, err := newSession() if err != nil {fmt.Println("failed to create session,", err)return } svc := s3.New(sess)resp, err := svc.ListBuckets(&s3.ListBucketsInput{})

上傳 object

sess, err := newSession() if err != nil {fmt.Println("failed to create session,", err)return } svc := s3.New(sess)params := &s3.PutObjectInput{Bucket: aws.String(bucket), // Required Key: aws.String(object), // Required Body: bytes.NewReader([]byte(content)), } _, err = svc.PutObject(params)

列出一個 bucket 的所有 object

sess, err := newSession() if err != nil {fmt.Println("failed to create session,", err)return } svc := s3.New(sess)params := &s3.ListObjectsInput{Bucket: aws.String(bucket), // Required } resp, err := svc.ListObjects(params)

總結

以上是生活随笔為你收集整理的【golang】aws s3 go sdk的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。