[UMU 学 golang](4) 简单的 AWS S3 客户端

UMU · · 4798 次点击 · · 开始浏览

这是一个创建于的文章，其中的信息可能已经有所发展或是发生改变。

　　公司搞了一套兼容 Amazon S3 的云存储系统，用 C++ 写客户端很蛋疼，UMU 决定还是用 go 来写一个。

　　首先找到一个靠谱的开源项目，运行以下命令安装：

go get github.com/mitchellh/goamz

　　它内部还用到了 github.com/vaughan0/go-ini。

　　然后看一下例子：

package main

import (
  "github.com/mitchellh/goamz/aws"
  "github.com/mitchellh/goamz/s3"
  "log"
  "fmt"
)

func main() {
  auth, err := aws.EnvAuth()
  if err != nil {
    log.Fatal(err)
  }
  client := s3.New(auth, aws.USEast)
  resp, err := client.ListBuckets()

  if err != nil {
    log.Fatal(err)
  }

  log.Print(fmt.Sprintf("%T %+v", resp.Buckets[0], resp.Buckets[0]))
}

　　要改的地方不多：1、认证方式可以改为 aws.GetAuth，但这样容易暴露 AccessKey、SecretKey，所以 UMU 下面贴出的代码还是使用 aws.EnvAuth()。2、aws.USEast 改为我们自己的。3、UMU 加了列出所有文件的功能。详见代码：

package main

import (
	"fmt"
	"github.com/mitchellh/goamz/aws"
	"github.com/mitchellh/goamz/s3"
	"log"
)

func main() {
	auth, err := aws.EnvAuth()
	if err != nil {
		log.Fatal(err)
	}

	var cnc = aws.Region{
		"cnc", // Name
		"",    // EC2Endpoint
		"http://s3.bj.xs3cnc.com", // S3Endpoint
		"",    // S3BucketEndpoint
		false, // S3LocationConstraint
		false, // S3LowercaseBucket
		"",    // SDBEndpoint
		"",    // SNSEndpoint
		"",    // SQSEndpoint
		"",    // IAMEndpoint
		"",    // ELBEndpoint
		"",    // AutoScalingEndpoint
		"",    // RdsEndpoint
		"",    // Route53Endpoint
	}
	client := s3.New(auth, cnc)
	resp, err := client.ListBuckets()
	if err != nil {
		log.Fatal(err)
	}

	for _, b := range resp.Buckets {
		fmt.Printf("Bucket Name: %s\n", b.Name)
		bc, err := b.GetBucketContents()
		if err == nil {
			for _, key := range *bc {
				fmt.Printf("\t%s, %s, %d, %s, %s, %s\n",
					key.Key, key.LastModified, key.Size, key.StorageClass,
					key.Owner.ID, key.Owner.DisplayName)
			}
		}
	}
}

　　效果如下：