全部文档
当前文档
最近更新时间：2023-11-03 16:21:25
上传成功后，向回调地址POST数据。需要设置x-kss-callbackurl和x-kss-callbackbody请求头，详见文档上传回调处理。
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)
}
// 上传对象并设置回调，回调具体规则请查阅文档：https://docs.ksyun.com/documents/956
// 在调用Put Object，Complete Multipart Upload接口时，可携带相关的Callback参数，实现上传回调处理
// 客户端将文件及相关Callback请求头上传到KS3后，KS3会通过POST方法向用户的回调地址POST一段json数据，此json数据为客户端传入的x-kss-callbackbody请求头填充变量后转化得来
// 用户服务端正确处理回调后返回{"result":true}，如果回调处理错误返回{"result":false}则表示文件上传失败
// 如果用户服务端没有返回任何消息，则进入超时等待，默认等待时间为3秒，重试两次。只有在KS3服务端收到{"result":true}时，文件才真正上传成功
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"), // 请求体资源类型，非必填
CallbackUrl: aws.String("http://45.109.201.214:8080"), // 接收回调的服务器地址，支持http和https，必填
CallbackBody: aws.String("objectKey=${key}&etag=${etag}&uid=123"), // 回调参数，必填
})
if err != nil {
panic(err)
}
fmt.Println("结果：\n", awsutil.StringValue(resp))
}
纯净模式