代码拉取完成,页面将自动刷新
package alyoss
import (
"fmt"
"gitee.com/h79/goutils/common/filemgr/structs"
"gitee.com/h79/goutils/common/filemgr/tools"
"gitee.com/h79/goutils/common/logger"
"gitee.com/h79/goutils/common/result"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
"io"
)
// StreamUpload 流式上传
func (of *OssFile) StreamUpload(fileResult *structs.FileResult, data *structs.FileStream, bucket *oss.Bucket) error {
if data.Size <= of.config.FileConfig.MinChunkSize {
if _, err := data.Seeker.Seek(0, io.SeekStart); err != nil {
return result.Error(result.ErrUpload,
fmt.Sprintf("Stream: File Seek failure, err= %v", err))
}
if err := bucket.PutObject(data.Key, data.Reader); err != nil {
return result.Error(result.ErrUpload,
fmt.Sprintf("Stream: Bucket put object failure, err= %v", err))
}
logger.Debug("Stream: Completed put object")
return nil
}
return of.streamPartUpload(fileResult, data, bucket)
}
func (of *OssFile) streamPartUpload(fileResult *structs.FileResult, data *structs.FileStream, bucket *oss.Bucket) error {
//分片处理
imur, err := bucket.InitiateMultipartUpload(data.Key)
if err != nil {
return result.Error(result.ErrUpload,
fmt.Sprintf("Stream: Bucket InitiateMultipartUpload failure, err= %v", err))
}
fileResult.Id = imur.UploadID
chunks := tools.Chunk(data.Size, tools.ChunkNum(data.Size, of.config.FileConfig.MinChunkSize))
// 对每个分片调用UploadPart方法上传。
var parts []oss.UploadPart
for _, chunk := range chunks {
_, er := data.Seeker.Seek(chunk.Offset, io.SeekStart)
if er != nil {
return result.Error(result.ErrUpload,
fmt.Sprintf("Stream: Bucket part file seek failure, err= %v", er))
}
part, er1 := bucket.UploadPart(imur, data.Reader, chunk.Size, chunk.Number)
if er1 != nil {
return result.Error(result.ErrUpload,
fmt.Sprintf("Stream: Bucket part file failure, err= %v", er1))
}
parts = append(parts, part)
}
// 完成分片上传
cmur, er2 := bucket.CompleteMultipartUpload(imur, parts)
if er2 != nil {
return result.Error(result.ErrUpload,
fmt.Sprintf("Stream: Bucket complete part failure, err= %v", er2))
}
logger.Info("Stream: Complete part, data= %v", cmur)
return nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。