简单上传（Go）

简单上传

以下代码用于上传文件：

package main

import (
	"bytes"
	"fmt"
	"github.com/ks3sdklib/aws-sdk-go/aws"
	"github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
	"github.com/ks3sdklib/aws-sdk-go/aws/credentials"
	"github.com/ks3sdklib/aws-sdk-go/service/s3"
	"io/ioutil"
)

func main() {
	// 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
	cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
	// 创建S3Client，更多配置项请查看Go-SDK初始化文档
	client := s3.New(&aws.Config{
		Credentials: cre,                          // 访问凭证
		Region:      "BEIJING",                    // 填写您的Region
		Endpoint:    "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
	})
	// 填写存储空间名称
	bucket := "<bucket_name>"
	// 填写对象的Key
	key := "<object_key>"
	// 填写上传文件路径
	filePath := "/Users/test/demo.txt"
	// 读取文件
	file, err := ioutil.ReadFile(filePath)
	if err != nil {
		panic(err)
	}
	// 简单上传对象
	resp, err := client.PutObject(&s3.PutObjectInput{
		Bucket:      aws.String(bucket),                     // 存储空间名称，必填
		Key:         aws.String(key),                        // 对象的Key，必填、
		Body:        bytes.NewReader(file),                  // 要上传的文件，必填
		ACL:         aws.String("public-read"),              // 对象访问权限，非必填
		ContentType: aws.String("application/octet-stream"), // 请求体资源类型，非必填
		Metadata: map[string]*string{
			"Key": aws.String("MetadataValue"), // 设置对象元数据，非必填
		},
	})
	if err != nil {
		panic(err)
	}
	fmt.Println("结果：\n", awsutil.StringValue(resp))

上传文件的更多信息，请参见 PUT Object 。

上传加密

以下代码用于上传加密：

package main

import (
    "bytes"
    "fmt"
    "github.com/ks3sdklib/aws-sdk-go/aws"
    "github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
    "github.com/ks3sdklib/aws-sdk-go/aws/credentials"
    "github.com/ks3sdklib/aws-sdk-go/service/s3"
    "io/ioutil"
)

func main() {
    // 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
    cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
    // 创建S3Client，更多配置项请查看Go-SDK初始化文档
    client := s3.New(&aws.Config{
        Credentials: cre,                          // 访问凭证
        Region:      "BEIJING",                    // 填写您的Region
        Endpoint:    "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
    })
    // 填写存储空间名称
    bucket := "<bucket_name>"
    // 填写对象的Key
    key := "<object_key>"
    // 填写上传文件路径
    filePath := "/Users/test/demo.txt"
    // 读取文件
    file, err := ioutil.ReadFile(filePath)
    if err != nil {
        panic(err)
    }
    // 服务器端加密关乎静态数据加密，即KS3在将您的数据写入数据中心内的磁盘时会在对象级别上加密这些数据，并在您访问这些数据时为您解密这些数据。
    // 只要您验证了您的请求并且拥有访问权限，您访问加密和未加密数据元的方式就没有区别。
    // 例如，如果您使用预签名的URL来共享您的对象，那么对于加密和解密对象，该URL的工作方式是相同的。
    // 上传文件，通过客户端提供的加密密钥加密
    resp, err := client.PutObject(&s3.PutObjectInput{
        Bucket:               aws.String(bucket),                                         // 存储空间名称，必填
        Key:                  aws.String(key),                                            // 对象的Key，必填
        Body:                 bytes.NewReader(file),                                      // 要上传的文件内容，必填
        SSECustomerAlgorithm: aws.String("AES256"),                                       // 客户端提供的加密算法，合法值：AES256
        SSECustomerKey:       aws.String("WKEOUdGRnEK7HISNCOjMjM0NTY3ODlBQkNER5AldAUY="), // 客户端提供的加密密钥
        SSECustomerKeyMD5:    aws.String("mrtoxMuTClsH3tw78pFoIA=="),                     // 客户端提供的通过BASE64编码的通过128位MD5加密的密钥的MD5值
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("结果：\n", awsutil.StringValue(resp))
}

创建文件夹

以下代码用于创建文件夹：

package main

import (
    "fmt"
    "github.com/ks3sdklib/aws-sdk-go/aws"
    "github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
    "github.com/ks3sdklib/aws-sdk-go/aws/credentials"
    "github.com/ks3sdklib/aws-sdk-go/service/s3"
)

func main() {
    // 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
    cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
    // 创建S3Client，更多配置项请查看Go-SDK初始化文档
    client := s3.New(&aws.Config{
        Credentials: cre,                          // 访问凭证
        Region:      "BEIJING",                    // 填写您的Region
        Endpoint:    "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
    })
    // 填写存储空间名称
    bucket := "<bucket_name>"
    // 填写文件夹的名称，文件夹名称要以/结尾
    key := "folder/"
    // 创建文件夹
    resp, err := client.PutObject(&s3.PutObjectInput{
        Bucket: aws.String(bucket), // 存储空间名称，必填
        Key:    aws.String(key),    // 文件夹名称，必填
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("结果：\n", awsutil.StringValue(resp))
}

上传文件流

以下代码用于上传文件流：

package main

import (
    "fmt"
    "github.com/ks3sdklib/aws-sdk-go/aws"
    "github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
    "github.com/ks3sdklib/aws-sdk-go/aws/credentials"
    "github.com/ks3sdklib/aws-sdk-go/service/s3"
    "os"
)

func main() {
    // 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
    cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
    // 创建S3Client，更多配置项请查看Go-SDK初始化文档
    client := s3.New(&aws.Config{
        Credentials: cre,                          // 访问凭证
        Region:      "BEIJING",                    // 填写您的Region
        Endpoint:    "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
    })
    // 填写存储空间名称
    bucket := "<bucket_name>"
    // 填写对象的key
    key := "<object_key>"
    // 打开文件
    fd, err := os.Open("/Users/test/demo.txt")
    if err != nil {
        panic(err)
    }
    defer fd.Close()
    // 上传文件流
    resp, err := client.PutObject(&s3.PutObjectInput{
        Bucket: aws.String(bucket), // 存储空间名称，必填
        Key:    aws.String(key),    // 对象的key，必填、
        Body:   fd,                 // 要上传的文件，必填
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("结果：\n", awsutil.StringValue(resp))
}

上传字符串

以下代码用于上传字符串：

package main

import (
    "fmt"
    "github.com/ks3sdklib/aws-sdk-go/aws"
    "github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
    "github.com/ks3sdklib/aws-sdk-go/aws/credentials"
    "github.com/ks3sdklib/aws-sdk-go/service/s3"
    "strings"
)

func main() {
    // 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
    cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
    // 创建S3Client，更多配置项请查看Go-SDK初始化文档
    client := s3.New(&aws.Config{
        Credentials: cre,                          // 访问凭证
        Region:      "BEIJING",                    // 填写您的Region
        Endpoint:    "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
    })
    // 填写存储空间名称
    bucket := "<bucket_name>"
    // 填写对象的key
    key := "<object_key>"
    // 上传字符串
    resp, err := client.PutObject(&s3.PutObjectInput{
        Bucket: aws.String(bucket),                // 存储空间名称，必填
        Key:    aws.String(key),                   // 对象的key，必填、
        Body:   strings.NewReader("test content"), // 要上传的文件，必填
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("结果：\n", awsutil.StringValue(resp))
}

上传Byte数组

以下代码用于上传Byte数组：

package main

import (
    "bytes"
    "fmt"
    "github.com/ks3sdklib/aws-sdk-go/aws"
    "github.com/ks3sdklib/aws-sdk-go/aws/awsutil"
    "github.com/ks3sdklib/aws-sdk-go/aws/credentials"
    "github.com/ks3sdklib/aws-sdk-go/service/s3"
)

func main() {
    // 创建访问凭证，请将<AccessKeyID>与<SecretAccessKey>替换成真正的值
    cre := credentials.NewStaticCredentials("<AccessKeyID>", "<SecretAccessKey>", "")
    // 创建S3Client，更多配置项请查看Go-SDK初始化文档
    client := s3.New(&aws.Config{
        Credentials: cre,                          // 访问凭证
        Region:      "BEIJING",                    // 填写您的Region
        Endpoint:    "ks3-cn-beijing.ksyuncs.com", // 填写您的Endpoint
    })
    // 填写存储空间名称
    bucket := "<bucket_name>"
    // 填写对象的key
    key := "<object_key>"
    // 上传Byte数组
    resp, err := client.PutObject(&s3.PutObjectInput{
        Bucket: aws.String(bucket),                      // 存储空间名称，必填
        Key:    aws.String(key),                         // 对象的key，必填、
        Body:   bytes.NewReader([]byte("test content")), // 要上传的文件，必填
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("结果：\n", awsutil.StringValue(resp))
}