快速入门

简介

本章节介绍如何快速使用 SDK 完成常见操作，包括创建桶、上传文件、下载文件等。

代码中，access key 与 secret access key 是您在开通 EOS 服务后，系统分配给您用于访问对象存储的凭证。 endpoint 是 EOS 对象存储的服务地址，Region 是所在地域，例如：

Endpoint	Region
http://s3.mediacloud.imgo.tv	cn-changsha-1

具体参见：对象存储 SDK 与 REST 对外接口地址

创建桶

存储桶是您用于存储文件 (Object) 的容器，在上传任何文件到 EOS 之前，您必须先创建存储桶。

以下代码用于创建桶：

package main

import (
  "fmt"
  "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"
  "os"
)

func exitErrorf(msg string, args ...interface{}) {
  fmt.Fprintf(os.Stderr, msg+"\n", args...)
  os.Exit(1)
}

func main() {
  sess, err := session.NewSession(&aws.Config{
    Region:      aws.String("Region"),
    Endpoint:    aws.String("your-endpoint"),
    Credentials: credentials.NewStaticCredentials("your-access-key", "your-secret-access-key", ""),
  })
  svc := s3.New(sess)
  bucketName := "your-bucket-name"
  params := &s3.CreateBucketInput{
    Bucket: aws.String(bucketName),
  }
  _, err = svc.CreateBucket(params)
  if err != nil {
    exitErrorf("Unable to create bucket %q, %v", bucketName, err)
  }
  fmt.Printf("Bucket %q created successfully\n", bucketName)
}

上传文件

以下代码用于上传文件：

package main

import (
    "fmt"
    "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/s3manager"
    "os"
)

func exitErrorf(msg string, args ...interface{}) {
    fmt.Fprintf(os.Stderr, msg+"", args...)
    os.Exit(1)
}

func main() {
    sess, err := session.NewSession(&aws.Config{
        Region:      aws.String("Region"),
        Endpoint:    aws.String("your-endpoint"),
        Credentials: credentials.NewStaticCredentials("your-access-key", "your-secret-access-key", ""),
    })
    //桶名
    bucketName := "your-bucket-name"
    Key := "your-object-name"
    filePath := "文件路径"
    file, err := os.Open(filePath)
    if err != nil {
        exitErrorf("Unable to open file %q, %v", err)
    }
    defer file.Close()
    uploader := s3manager.NewUploader(sess)
    _, err = uploader.Upload(&s3manager.UploadInput{
        Bucket: aws.String(bucketName),
        Key:    aws.String(Key),
        Body:   file,
    })
    if err != nil {
        // Print the error and exit.
        exitErrorf("Unable to upload %q to %q, %v", Key, bucketName, err)
    }
    fmt.Printf("Successfully uploaded %q to %q", Key, bucketName)
}

注意

上传文件（Object）时，如果未指定文件（Object）权限，则上传文件（Object）默认为私有访问权限。

下载文件

以下代码用于下载文件：

package main

import (
    "fmt"
    "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"
    "github.com/aws/aws-sdk-go/service/s3/s3manager"
    "os"
)

func exitErrorf(msg string, args ...interface{}) {
    fmt.Fprintf(os.Stderr, msg+"\n", args...)
    os.Exit(1)
}

func main() {
    sess, err := session.NewSession(&aws.Config{
        Region:      aws.String("Region"),
        Endpoint:    aws.String("your-endpoint"),
        Credentials: credentials.NewStaticCredentials("your-access-key", "your-secret-access-key", ""),
    })
    bucketName := "your-bucket-name"
    Key := "your-object-name"
    file, err := os.Create(Key)
    if err != nil {
        exitErrorf("Unable to open file %q, %v", err)
    }
    defer file.Close()
    downloader := s3manager.NewDownloader(sess)
    numBytes, err := downloader.Download(file,
        &s3.GetObjectInput{
            Bucket: aws.String(bucketName),
            Key:    aws.String(Key),
        })
    if err != nil {
        exitErrorf("Unable to download file %q, %v", Key, err)
    }
    fmt.Println("Downloaded", file.Name(), numBytes, "bytes")
}