• 如何使用AWS SDK for Go操作Minio Server
    • 1. 前提条件
    • 2. 安装
    • 3. 示例
    • 4. 运行程序

    如何使用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