服务端加密(go sdk)-九游平台

packagemain
import(
"crypto/md5"
"encoding/base64"
"fmt"
"os"
"strings"
obs"github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)
funcmain(){
//推荐通过环境变量获取aksk，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
//您可以登录访问管理控制台获取访问密钥ak/sk，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
ak:=os.getenv("accesskeyid")
sk:=os.getenv("secretaccesskey")
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。
// securitytoken := os.getenv("securitytoken")
// endpoint填写bucket对应的endpoint, 这里以华北-北京四为例，其他地区请按实际情况填写。
endpoint:="https://obs.cn-north-4.myhuaweicloud.com"
// 创建obsclient实例
// 如果使用临时aksk和securitytoken访问obs，需要在创建实例时通过obs.withsecuritytoken方法指定securitytoken值。
obsclient,err:=obs.new(ak,sk,endpoint/*, obs.withsecuritytoken(securitytoken)*/)
iferr!=nil{
fmt.printf("create obsclient error, errmsg: %s",err.error())
}
input:=&obs.putobjectinput{}
// 指定存储桶名称
input.bucket="examplebucket"
// 指定上传对象名，此处以 example/objectname 为例。
input.key="example/objectname"
// 指定上传的内容
input.body=strings.newreader("hello obs")
// 指定服务端加密头信息，此处以 obs.ssecheader为例
key:=os.getenv("key")
digest:=md5.new()
digest.write([]byte(key))
bodyhash:=digest.sum(nil)
input.sseheader=obs.ssecheader{
encryption:"aes256",
key:base64.stdencoding.encodetostring([]byte(key)),// 32byteslongsecretkeymustprovided
keymd5:base64.stdencoding.encodetostring(bodyhash),
}
// 流式上传本地文件
output,err:=obsclient.putobject(input)
iferr==nil{
fmt.printf("put object(%s) under the bucket(%s) successful!\n",input.key,input.bucket)
fmt.printf("requestid:%s\n",output.requestid)
fmt.printf("storageclass:%s, etag:%s\n",
output.storageclass,output.etag)
return
}
fmt.printf("put object(%s) under the bucket(%s) fail!\n",input.key,input.bucket)
ifobserror,ok:=err.(obs.obserror);ok{
fmt.println("an obserror was found, which means your request sent to obs was rejected with an error response.")
fmt.println(obserror.error())
}else{
fmt.println("an exception was found, which means the client encountered an internal problem when attempting to communicate with obs, for example, the client was unable to access the network.")
fmt.println(err)
}
}

packagemain
import(
"crypto/md5"
"encoding/base64"
"fmt"
"os"
obs"github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)
funcmain(){
// 您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。如果使用硬编码可能会存在泄露风险。
// 您可以登录访问管理控制台获取访问密钥ak/sk，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
ak:=os.getenv("accesskeyid")
sk:=os.getenv("secretaccesskey")
// 【可选】如果使用临时ak/sk和securitytoken访问obs，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥ak/sk，也可以使用其他外部引入方式传入。
// securitytoken := os.getenv("securitytoken")
// endpoint填写bucket对应的endpoint, 这里以华北-北京四为例，其他地区请按实际情况填写。
endpoint:="https://obs.cn-north-4.myhuaweicloud.com"
// 创建obsclient实例
// 如果使用临时aksk和securitytoken访问obs，需要在创建实例时通过obs.withsecuritytoken方法指定securitytoken值。
obsclient,err:=obs.new(ak,sk,endpoint/*, obs.withsecuritytoken(securitytoken)*/)
iferr!=nil{
fmt.printf("create obsclient error, errmsg: %s",err.error())
}
input:=&obs.getobjectinput{}
// 指定存储桶名称
input.bucket="examplebucket"
// 指定下载对象，此处以 example/objectname 为例。
input.key="example/objectname"
// 指定服务端加密头信息，此处以 obs.ssecheader为例
key:=os.getenv("key")
digest:=md5.new()
digest.write([]byte(key))
bodyhash:=digest.sum(nil)
input.sseheader=obs.ssecheader{
encryption:"aes256",
key:base64.stdencoding.encodetostring([]byte(key)),// 32byteslongsecretkeymustprovided
keymd5:base64.stdencoding.encodetostring(bodyhash),
}
// 流式下载对象
output,err:=obsclient.getobject(input)
iferr==nil{
// output.body 在使用完毕后必须关闭，否则会造成连接泄漏。
deferoutput.body.close()
fmt.printf("get object(%s) under the bucket(%s) successful!\n",input.key,input.bucket)
fmt.printf("storageclass:%s, etag:%s, contenttype:%s, contentlength:%d, lastmodified:%s\n",
output.storageclass,output.etag,output.contenttype,output.contentlength,output.lastmodified)
// 读取对象内容
p:=make([]byte,1024)
varreaderrerror
varreadcountint
for{
readcount,readerr=output.body.read(p)
ifreadcount>0{
fmt.printf("%s",p[:readcount])
}
ifreaderr!=nil{
break
}
}
return
}
fmt.printf("list objects under the bucket(%s) fail!\n",input.bucket)
ifobserror,ok:=err.(obs.obserror);ok{
fmt.println("an obserror was found, which means your request sent to obs was rejected with an error response.")
fmt.println(obserror.error())
}else{
fmt.println("an exception was found, which means the client encountered an internal problem when attempting to communicate with obs, for example, the client was unable to access the network.")
fmt.println(err)
}
}