diff --git a/pkg/service/common/common.go b/pkg/service/common/common.go index f95b602..c6e14cd 100644 --- a/pkg/service/common/common.go +++ b/pkg/service/common/common.go @@ -212,7 +212,7 @@ func GetSnapshot(videoPath, snapshotPath string, frameNum int) (snapshotName str } func PutBos(filePath string, mediaType string, needRemove bool) (url string, err error) { - BOSClient, err := objstorage.NewOSS(config.Data.Bos.AccessKeyId, config.Data.Bos.AccessKeySecret, objstorage.BOS_BJ) + BOSClient, err := objstorage.NewOSS(config.Data.Bos.AccessKeyId, config.Data.Bos.AccessKeySecret, config.Data.Bos.Endpoint) if err != nil { logger.Errorf("PutBos NewOSS err ", err) err = errors.New(msg.ErrorUploadBos) @@ -258,7 +258,7 @@ func quickBos(file *multipart.FileHeader, mediaType string, mask string, source } } var objectName string = fmt.Sprintf("%s/%s/%s", config.Data.Bos.BosBaseDir, config.Data.System.Mode, filePath) - BOSClient, _ := objstorage.NewOSS(config.Data.Bos.AccessKeyId, config.Data.Bos.AccessKeySecret, objstorage.BOS_BJ) + BOSClient, _ := objstorage.NewOSS(config.Data.Bos.AccessKeyId, config.Data.Bos.AccessKeySecret, config.Data.Bos.Endpoint) _, err = BOSClient.PutObjectFromBytes(config.Data.Bos.BucketName, objectName, fileBytes) if err != nil { logger.Errorf("quickBos err", err)