代码拉取完成,页面将自动刷新
package qnyoss
import (
"context"
"fmt"
"gitee.com/h79/goutils/common/filemgr/config"
"gitee.com/h79/goutils/common/filemgr/structs"
"github.com/qiniu/api.v7/v7/auth"
"github.com/qiniu/api.v7/v7/storage"
)
type OssFile struct {
config config.Config
}
func NewOssFile(config config.Config) *OssFile {
return &OssFile{config: config}
}
// UploadToken 获取七牛云Token
func (of *OssFile) UploadToken(bucket string, key string) string {
putPolicy := storage.PutPolicy{
Scope: fmt.Sprintf("%s:%s", bucket, key),
}
putPolicy.Expires = uint64(of.config.Expires)
cred := auth.New(of.config.AccessKey, of.config.SecretKey)
return putPolicy.UploadToken(cred)
}
func (of *OssFile) UploadStream(fileResult *structs.FileResult, stream *structs.FileStream) error {
upToken := of.UploadToken(stream.Bucket, stream.Key)
region, exist := storage.GetRegionByID(storage.RegionID(of.config.Region))
if !exist {
return fmt.Errorf("region not found")
}
cfg := storage.Config{}
// 空间对应的机房
cfg.Zone = ®ion
// 是否使用https域名
cfg.UseHTTPS = of.config.UseHTTPS
// 上传是否使用CDN上传加速
cfg.UseCdnDomains = of.config.UseCdn
formUploader := storage.NewFormUploader(&cfg)
ret := storage.PutRet{}
extra := storage.PutExtra{}
if err := formUploader.Put(context.Background(),
&ret, upToken, stream.Key, stream.Reader, stream.Size, &extra); err != nil {
return err
}
fileResult.Key = ret.Key
fileResult.Url = of.config.FileConfig.Cdn + fileResult.Key
return nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。