如何使用AWS SDK for Go操作Minio Server

aws-sdk-go是GO语言版本的官方AWS SDK。本文将学习如何使用aws-sdk-go来操作Minio Server。

1. 前提条件

从这里下载并安装Minio Server。

2. 安装

从AWS SDK for GO官方文档下载将安装aws-sdk-go。

3. 示例

替换example.go文件中的Endpoint,Credentials, Bucket配置成你的本地配置。

下面的示例讲的是如何使用aws-sdk-go从Minio Server上putObject和getObject。

  1. package main
  3. import (
  4.     "fmt"
  5.     "os"
  6.     "strings"
  8.     "github.com/aws/aws-sdk-go/aws"
  9.     "github.com/aws/aws-sdk-go/aws/credentials"
  10.     "github.com/aws/aws-sdk-go/service/s3/s3manager"
  11.     "github.com/aws/aws-sdk-go/aws/session"
  12.     "github.com/aws/aws-sdk-go/service/s3"
  13. )
  15. func main() {
  16.     bucket := aws.String("newbucket")
  17.     key := aws.String("testobject")
  19.     //  配置成使用Minio Server。
  20.     s3Config := &aws.Config{
  21.         Credentials:      credentials.NewStaticCredentials("YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY", ""),
  22.         Endpoint:         aws.String("http://localhost:9000"),
  23.         Region:           aws.String("us-east-1"),
  24.         DisableSSL:       aws.Bool(true),
  25.         S3ForcePathStyle: aws.Bool(true),
  26.     }
  27.     newSession := session.New(s3Config)
  29.     s3Client := s3.New(newSession)
  31.     cparams := &s3.CreateBucketInput{
  32.         Bucket: bucket, // 必须
  33.     }
  35.     // 调用CreateBucket创建一个新的存储桶。
  36.     _, err := s3Client.CreateBucket(cparams)
  37.     if err != nil {
  38.         // 错误信息
  39.         fmt.Println(err.Error())
  40.         return
  41.     }
  43.     // 上传一个新的文件"testobject"到存储桶"newbucket",内容是"Hello World!" 。
  44.     _, err = s3Client.PutObject(&s3.PutObjectInput{
  45.         Body:   strings.NewReader("Hello from Minio!!"),
  46.         Bucket: bucket,
  47.         Key:    key,
  48.     })
  49.     if err != nil {
  50.         fmt.Printf("Failed to upload data to %s/%s, %s\n", *bucket, *key, err.Error())
  51.         return
  52.     }
  53.     fmt.Printf("Successfully created bucket %s and uploaded data with key %s\n", *bucket, *key)
  55.     // 从 "newbucket"里获取文件"testobject"，并保存到本地文件"testobject_local"。
  56.     file, err := os.Create("testobject_local")
  57.     if err != nil {
  58.         fmt.Println("Failed to create file", err)
  59.         return
  60.     }
  61.     defer file.Close()
  63.     downloader := s3manager.NewDownloader(newSession)
  64.     numBytes, err := downloader.Download(file,
  65.     &s3.GetObjectInput{
  66.         Bucket: bucket,
  67.         Key:    key,
  68.     })
  69.     if err != nil {
  70.         fmt.Println("Failed to download file", err)
  71.         return
  72.     }
  73.     fmt.Println("Downloaded file", file.Name(), numBytes, "bytes")
  74. }

4. 运行程序

  1. go run example.go
  2. Successfully created bucket newbucket and uploaded data with key testobject
  3. Downloaded file testobject_local 18 bytes

原文: https://docs.minio.io/cn/how-to-use-aws-sdk-for-go-with-minio-server.html