上传回调（Go）

上传成功后，向回调地址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))
}