公司搞了一套兼容 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\n",key.Key,key.LastModified,key.Size,key.StorageClass,key.Owner.ID,key.Owner.DisplayName) } } } }
效果如下:
参照对象:
原文链接:https://www.f2er.com/go/190185.html