public_project/utility_go
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

为了兼容七牛云接口，s3强制使用路径风格

Browse Source
This commit is contained in:
ayflying
2025-06-11 11:02:21 +08:00
parent c673da89cf
commit 8e2301eb34
1 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
pkg/s3/s3.go
View File

@@ -24,12 +24,12 @@ var (
// DataType 定义了 S3 配置的数据结构，用于存储访问 S3 所需的各种信息 // DataType 定义了 S3 配置的数据结构，用于存储访问 S3 所需的各种信息
type DataType struct { type DataType struct {
AccessKey string `json:"access_key"` // 访问 S3 的密钥 ID AccessKey string `json:"access_key"` // 访问 S3 的密钥 ID
SecretKey string `json:"secret_key"` // 访问 S3 的密钥 SecretKey string `json:"secret_key"` // 访问 S3 的密钥
Address string `json:"address"` // S3 服务的地址 Address string `json:"address"` // S3 服务的地址
Ssl bool `json:"ssl"` // 是否使用 SSL 加密连接 Ssl bool `json:"ssl"` // 是否使用 SSL 加密连接
Url string `json:"url"` // S3 服务的访问 URL Url string `json:"url"` // S3 服务的访问 URL
BucketName string `json:"bucket_name"` // 默认存储桶名称 BucketName string `json:"bucket_name"` // 默认存储桶名称
BucketNameCdn string `json:"bucket_name_cdn"` // CDN 存储桶名称 BucketNameCdn string `json:"bucket_name_cdn"` // CDN 存储桶名称
} }
@@ -62,8 +62,9 @@ func New(_name ...string) *Mod {
obj, err := minio.New( obj, err := minio.New(
cfg.Address, cfg.Address,
&minio.Options{ &minio.Options{
Creds: credentials.NewStaticV4(cfg.AccessKey, cfg.SecretKey, ""), Creds: credentials.NewStaticV4(cfg.AccessKey, cfg.SecretKey, ""),
Secure: cfg.Ssl, Secure: cfg.Ssl,
BucketLookup: minio.BucketLookupPath,
}, },
) )
if err != nil { if err != nil {
@@ -137,7 +138,9 @@ func (s *Mod) PutObject(f io.Reader, name string, bucketName string, _size ...in
size = _size[0] size = _size[0]
} }
// 调用 S3 客户端上传文件，设置内容类型为 "application/octet-stream" // 调用 S3 客户端上传文件，设置内容类型为 "application/octet-stream"
res, err = s.client.PutObject(ctx, bucketName, name, f, size, minio.PutObjectOptions{ContentType: "application/octet-stream"}) res, err = s.client.PutObject(ctx, bucketName, name, f, size, minio.PutObjectOptions{
ContentType: "application/octet-stream",
})
if err != nil { if err != nil {
// 记录上传错误日志 // 记录上传错误日志
g.Log().Error(ctx, err) g.Log().Error(ctx, err)
@@ -148,6 +151,7 @@ func (s *Mod) PutObject(f io.Reader, name string, bucketName string, _size ...in
// RemoveObject 从指定存储桶中删除指定名称的文件 // RemoveObject 从指定存储桶中删除指定名称的文件
func (s *Mod) RemoveObject(name string, bucketName string) (err error) { func (s *Mod) RemoveObject(name string, bucketName string) (err error) {
opts := minio.RemoveObjectOptions{ opts := minio.RemoveObjectOptions{
ForceDelete: true,
//GovernanceBypass: true, //GovernanceBypass: true,
//VersionID: "myversionid", //VersionID: "myversionid",
} }