存储空间 - 《阿里云对象存储 OSS Go SDK 文档》

创建存储空间
列举存储空间
判断存储空间是否存在
设置存储空间的访问权限
获取存储空间的访问权限
获取存储空间的地域
获取存储空间的信息
删除存储空间

存储空间（Bucket）是存储对象（Object）的容器。对象都隶属于存储空间。

创建存储空间

创建存储空间的完整代码请参见GitHub。

以下代码用于创建存储空间：

package main
    import (
        "fmt"
        "os"
        "github.com/aliyun/aliyun-oss-go-sdk/oss"
    )
func main() {
    // 创建OSSClient实例。
    client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 创建存储空间。默认为标准存储类型，私有权限。
    err = client.CreateBucket("<yourBucketName>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
}

存储空间的命名规范，请参见基本概念中的命名规范。您可以在创建存储空间时指定存储空间的权限和存储类型。

以下代码用于在创建存储空间时指定存储空间的权限：

    // 创建存储空间，并设置存储空间的权限为公共读（默认是私有）。
    err = client.CreateBucket("<yourBucketName>", oss.ACL(oss.ACLPublicRead))
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

以下代码用于创建归档类型的存储空间：

    err = client.CreateBucket("<yourBucketName>", oss.StorageClass(oss.StorageArchive))
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

以下代码用于创建低频访问类型的存储空间：

    err = client.CreateBucket("<yourBucketName>", oss.StorageClass(oss.StorageIA))
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

列举存储空间

列举存储空间的完整代码请参见GitHub。

列举所有的存储空间
存储空间按照字母顺序排列。您可以列举所有的存储空间，或符合指定条件的存储空间。

以下代码用于列举所有的存储空间：

package main
import (
    "fmt"
    "os"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
    // 创建OSSClient实例。
    client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 列举存储空间。
    marker := ""
    for {
        lsRes, err := client.ListBuckets(oss.Marker(marker))
        if err != nil {
            fmt.Println("Error:", err)
            os.Exit(-1)
        }
        // 默认情况下一次返回100条记录。 
        for _, bucket := range lsRes.Buckets {
            fmt.Println("Bucket: ", bucket.Name)
        }
        if lsRes.IsTruncated {
            marker = lsRes.NextMarker
        } else {
            break
        }
    }
}

列举指定前缀的存储空间
以下代码用于列举包含指定前缀（prefix）的存储空间：

// 列举指定前缀的存储空间。
    lsRes, err = client.ListBuckets(oss.Prefix("<yourBucketPrefix>"))
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 打印存储空间列表。
    fmt.Println("Buckets with prefix: ", lsRes.Buckets)
    for _, bucket := range lsRes.Buckets {
        fmt.Println("Bucket with prefix: ", bucket.Name)
    }

列举指定marker之后的存储空间
参数marker代表存储空间名称。以下代码用于列举指定marker之后的存储空间：

    // 列举指定marker之后的存储空间。
    lsRes, err = client.ListBuckets(oss.Marker("<yourBucketMarker>"))
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 打印存储空间列表。
    fmt.Println("My buckets with marker :", lsRes.Buckets)
    for _, bucket := range lsRes.Buckets {
        fmt.Println("Bucket with marker: ", bucket.Name)
    }

列举指定个数的存储空间
以下代码用于列举指定个数（maxKeys）的存储空间:

    // 限定此次列举存储空间的个数为500。默认值为100，最大值为1000。
    lsRes, err = client.ListBuckets(oss.MaxKeys(500))
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 打印存储空间列表。 
    fmt.Println("My buckets max num:", lsRes.Buckets)
    for _, bucket := range lsRes.Buckets {
        fmt.Println("Bucket with maxKeys: ", bucket.Name)
    }

判断存储空间是否存在

以下代码用于判断指定的存储空间是否存在：

package main
import (
    "fmt"
    "os"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
    // 创建OSSClient实例。
    client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 判断存储空间是否存在。
    isExist, err := client.IsBucketExist("<yourBucketName>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    fmt.Println("IsBucketExist result : ", isExist)
}

设置存储空间的访问权限

存储空间的访问权限（ACL）有以下三类：


访问权限	描述	访问权限值
私有	存储空间的拥有者和授权用户有文件的读写权限，其他用户没有权限操作文件。	oss.ACLPrivate
公共读	存储空间的拥有者和授权用户有文件的读写权限，其他用户只有读权限。请谨慎使用该权限。	oss.ACLPublicRead
公共读写	所有用户都有文件的读写权限。请谨慎使用该权限。	oss.ACLPublicReadWrite

更多关于访问权限的内容请参见开发指南中访问控制。存储空间访问权限的完整代码请参见GitHub。

以下代码用于设置存储空间的访问权限：

package main
import (
    "fmt"
    "os"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
    // 创建OSSClient实例。
    client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 设置存储空间的访问权限为公共读。
    err = client.SetBucketACL("<yourBucketName>", oss.ACLPublicRead)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
}

获取存储空间的访问权限

以下代码用于获取存储空间的访问权限：

package main
import (
    "fmt"
    "os"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
    // 创建OSSClient实例。
    client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 获取存储空间的访问权限。
    aclRes, err := client.GetBucketACL("<yourBucketName>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    fmt.Println("Bucket ACL:", aclRes.ACL)
}

获取存储空间的地域

以下代码用于获取存储空间的地域（称为Region或Location）：

package main
import (
    "fmt"
    "os"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
    // 创建OSSClient实例。
    client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 获取存储空间的地域。
    loc, err := client.GetBucketLocation("<yourBucketName>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    fmt.Println("Bucket Location:", loc)
}

获取存储空间的信息

以下代码用于获取存储空间的信息（Info）：

package main
import (
    "fmt"
    "os"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
    // 创建OSSClient实例。
    client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 存储空间的信息包括地域（Region或Location）、创建日期（CreationDate）、访问权限（ACL）、拥有者（Owner）、存储类型（StorageClass）等。
    res, err := client.GetBucketInfo("<yourBucketName>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    fmt.Println("BucketInfo.Location: ", res.BucketInfo.Location)
    fmt.Println("BucketInfo.CreationDate: ", res.BucketInfo.CreationDate)
    fmt.Println("BucketInfo.ACL: ", res.BucketInfo.ACL)
    fmt.Println("BucketInfo.Owner: ", res.BucketInfo.Owner)
    fmt.Println("BucketInfo.StorageClass: ", res.BucketInfo.StorageClass)
    fmt.Println("BucketInfo.ExtranetEndpoint: ", res.BucketInfo.ExtranetEndpoint)
    fmt.Println("BucketInfo.IntranetEndpoint: ", res.BucketInfo.IntranetEndpoint)
}

删除存储空间

删除存储空间之前，必须先删除存储空间下的所有文件、LiveChannel和分片上传产生的碎片。

说明要删除分片上传产生的碎片，首先使用Bucket.ListMultipartUploads列举出所有碎片，然后使用Bucket.AbortMultipartUpload删除这些碎片。详情请参见分片上传。

以下代码用于删除存储空间：

package main
import (
    "fmt"
    "os"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
    // 创建OSSClient实例。
    client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 删除存储空间。
    err = client.DeleteBucket("<yourBucketName>")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
}