本节介绍如何快速使用OSS Go SDK完成常见操作,如创建存储空间、上传文件、下载文件等。
创建存储空间
以下代码用于创建存储空间:
package main
import (
"fmt"
"os"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func handleError(err error) {
fmt.Println("Error:", err)
os.Exit(-1)
}
func main() {
// Endpoint以杭州为例,其它Region请按实际情况填写。
endpoint := "http://oss-cn-hangzhou.aliyuncs.com"
// 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
accessKeyId := "<yourAccessKeyId>"
accessKeySecret := "<yourAccessKeySecret>"
bucketName := "<yourBucketName>"
// 创建OSSClient实例。
client, err := oss.New(endpoint, accessKeyId, accessKeySecret)
if err != nil {
handleError(err)
}
// 创建存储空间。
err = client.CreateBucket(bucketName)
if err != nil {
handleError(err)
}
}
获取endpoint信息,请参见访问域名和数据中心文档。
上传文件
以下代码用于上传文件至OSS:
package main
import (
"fmt"
"os"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func handleError(err error) {
fmt.Println("Error:", err)
os.Exit(-1)
}
func main() {
// Endpoint以杭州为例,其它Region请按实际情况填写。
endpoint := "http://oss-cn-hangzhou.aliyuncs.com"
// 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
accessKeyId := "<yourAccessKeyId>"
accessKeySecret := "<yourAccessKeySecret>"
bucketName := "<yourBucketName>"
objectName := "<yourObjectName>"
localFileName := "<yourLocalFileName>"
// 创建OSSClient实例。
client, err := oss.New(endpoint, accessKeyId, accessKeySecret)
if err != nil {
handleError(err)
}
// 获取存储空间。
bucket, err := client.Bucket(bucketName)
if err != nil {
handleError(err)
}
// 上传文件。
err = bucket.PutObjectFromFile(objectName, localFileName)
if err != nil {
handleError(err)
}
}
下载文件
以下代码用于下载文件到本地:
package main
import (
"fmt"
"os"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func handleError(err error) {
fmt.Println("Error:", err)
os.Exit(-1)
}
func main() {
// Endpoint以杭州为例,其它Region请按实际情况填写。
endpoint := "http://oss-cn-hangzhou.aliyuncs.com"
// 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
accessKeyId := "<yourAccessKeyId>"
accessKeySecret := "<yourAccessKeySecret>"
bucketName := "<yourBucketName>"
objectName := "<yourObjectName>"
downloadedFileName := "<yourDownloadedFileName>"
// 创建OSSClient实例。
client, err := oss.New(endpoint, accessKeyId, accessKeySecret)
if err != nil {
handleError(err)
}
// 获取存储空间。
bucket, err := client.Bucket(bucketName)
if err != nil {
handleError(err)
}
// 下载文件。
err = bucket.GetObjectToFile(objectName, downloadedFileName)
if err != nil {
handleError(err)
}
}
列举文件
以下代码用于列举指定存储空间下的文件。默认列举100个文件。
package main
import (
"fmt"
"os"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func HandleError(err error) {
fmt.Println("Error:", err)
os.Exit(-1)
}
func main() {
// 创建OSSClient实例。
client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
if err != nil {
HandleError(err)
}
// 获取存储空间。
bucketName := "<yourBucketName>"
bucket, err := client.Bucket(bucketName)
if err != nil {
HandleError(err)
}
// 列举文件。
marker := ""
for {
lsRes, err := bucket.ListObjects(oss.Marker(marker))
if err != nil {
HandleError(err)
}
// 打印列举文件,默认情况下一次返回100条记录。
for _, object := range lsRes.Objects {
fmt.Println("Bucket: ", object.Key)
}
if lsRes.IsTruncated {
marker = lsRes.NextMarker
} else {
break
}
}
}
删除文件
以下代码用于删除指定文件:
package main
import (
"fmt"
"os"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func handleError(err error) {
fmt.Println("Error:", err)
os.Exit(-1)
}
func main() {
// Endpoint以杭州为例,其它Region请按实际情况填写。
endpoint := "http://oss-cn-hangzhou.aliyuncs.com"
// 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
accessKeyId := "<yourAccessKeyId>"
accessKeySecret := "<yourAccessKeySecret>"
bucketName := "<yourBucketName>"
objectName := "<yourObjectName>"
// 创建OSSClient实例。
client, err := oss.New(endpoint, accessKeyId, accessKeySecret)
if err != nil {
handleError(err)
}
// 获取存储空间。
bucket, err := client.Bucket(bucketName)
if err != nil {
handleError(err)
}
// 删除文件。
err = bucket.DeleteObject(objectName)
if err != nil {
handleError(err)
}
}