公司搞了一套兼容 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)
}
}
}
}
效果如下:
参照对象: