golangで、S3のBucket以下のObjectを全て操作する

いくつかのサイトで、S3のObjectの操作を調べたのですが、有名なサイトでも、私が望んていた処理が一部満たされていない（1,000件以上のObjectの操作が出来ないなど)かったので、今回 go-lang で実装してみました。

注意点

• AWS の API の仕様で、一度に１，０００件までの Object しか取得できない
• ec2 上で実行した方が、料金を抑えることができるはず

前提条件

• AWS CLI の設定が終わっていること。

実装

package main

import (
    "flag"
    "fmt"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/service/s3"
)

var bucket string

// Regsion
const Region = "us-west-1"

func main() {
    flag.Parse()
    fmt.Println("flag.Args: ", flag.Args())
    fmt.Println(flag.Args()[0])

    bucket = flag.Args()[0]

    getS3Objects("prefix/")

}

func getS3Objects(prefix string) bool {

    var re = Region
    cli := s3.New(&aws.Config{Region: &re})

    params := &s3.ListObjectsInput{
        Bucket: aws.String(bucket),
        Prefix: aws.String(prefix),
    }

    cli.ListObjectsPages(params, addAclPublicRead)

    return true
}

func addAclPublicRead(resps *s3.ListObjectsOutput, more bool) bool {

    var re = Region
    cli := s3.New(&aws.Config{Region: &re})

    for n := 0; n < len(resps.Contents); n++ {
        params := &s3.PutObjectAclInput{
            Bucket: aws.String(bucket),
            Key:    aws.String(*resps.Contents[n].Key),
            ACL:    aws.String(s3.ObjectCannedACLPublicRead),
        }
        resp, err := cli.PutObjectAcl(params)

        if err != nil {
            fmt.Println(err.Error())
            return false
        }

        // Pretty-print the response data.
        fmt.Println(resp)
    }
    return true
}