go语言对接S3存储的SDK(支持minio和OSS)

2024-06-21 01:04

本文主要是介绍go语言对接S3存储的SDK(支持minio和OSS),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

背景

在某个项目中,客户要求支持S3协议的存储,因为之前的项目是go来开发的支持的oss和minio 。
但并不一定支持S3的协议,而且使用了二种SDK,感觉比较麻烦。
既然客户提出来了要求。那我们改一下就是了。 

操作

引入

go语言中有对s2存储有二个版本,这里我们使用v2的版本。

主要看 使用的是v2版本

这里我引入了4个包 以及对应的版本, 大家可以直接go get 下载最新的应该也是可以的
比如: get get github.com/aws/aws-sdk-go-v2

	github.com/aws/aws-sdk-go-v2 v1.30.0github.com/aws/aws-sdk-go-v2/config v1.27.21github.com/aws/aws-sdk-go-v2/credentials v1.17.21github.com/aws/aws-sdk-go-v2/service/s3 v1.56.1

代码实现

工具类

type S3Client struct {endpoint        stringaccessKeyId     stringaccessKeySecret stringclient          *s3.Clientbucket          stringregion          string
}func NewS3Client(endpoint, akId, akSecret, region string) S3Client {return S3Client{endpoint:        endpoint,accessKeyId:     akId,accessKeySecret: akSecret,region:          region,}
}func (c *S3Client) InitClient(bucket string, UsePathStyle bool) error {cfg, err := config.LoadDefaultConfig(context.TODO(),config.WithRegion(c.region),config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider(c.accessKeyId, c.accessKeySecret, "")),config.WithEndpointResolver(aws.EndpointResolverFunc(func(service, region string) (aws.Endpoint, error) {return aws.Endpoint{URL: c.endpoint,}, nil})),)c.bucket = bucketif err != nil {return err}c.client = s3.NewFromConfig(cfg, func(o *s3.Options) {o.UsePathStyle = UsePathStyle})return nil
}func (c *S3Client) PutObj(bucket, project, data string) error {_, err := c.client.PutObject(context.TODO(), &s3.PutObjectInput{Bucket: aws.String(bucket),Key:    aws.String(project),Body:   strings.NewReader(data),})return err
}func (c *S3Client) PutObjUseDefBucket(project, data string) error {if c.bucket == "nil" {return &thisErr{"Default Bucket is nil !!!"}}return c.PutObj(c.bucket, project, data)
}type thisErr struct {S string
}func (e thisErr) Error() string {return e.S
}

调用

func Init() bool {c.ossClt = S3OSSCliet.NewS3Client(Config.C.OssEndpoint, Config.C.OssAkId, Config.C.OssAkSecret, Config.C.Region)e := c.ossClt.InitClient(Config.C.OssBucket, Config.C.OSSType == "1")if e != nil {logger.Logf(logger.ERROR, "Init Oss Client Error! err:%s", e)}e = c.ossClt.PutObjUseDefBucket("路径", "base64的图片数据")return true
}

我这里的4个参数是写成了配置的, 大家测试的时候修改成自己的参数就可以了。
另外需要修改路径和一个base64的图片数据就可以了,这个简单相信大家都会弄的。
我这里就不写了。

配置文件

 <OssEndpoint>http://xxx:9000/</OssEndpoint><OssAkId>xxx</OssAkId><OssAkSecret>minioadmin</OssAkSecret><OssBucket>test</OssBucket><Region>us-west-2</Region><!--    0: AliyunOSS    1:minioOSS--><OSSType>1</OSSType>

遇到的问题点

解决go语言对接s3的SDK上传文件遇到的问题
里面有说具体的问题点、原因。
当然如果按照我上述配置的话,不会存在问题。
坑的话我已经踩过了。

测试

minio上传成功

在这里插入图片描述

oss上传成功

在这里插入图片描述

这篇关于go语言对接S3存储的SDK(支持minio和OSS)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1079773

相关文章

MySQL存储过程之循环遍历查询的结果集详解

《MySQL存储过程之循环遍历查询的结果集详解》:本文主要介绍MySQL存储过程之循环遍历查询的结果集,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言1. 表结构2. 存储过程3. 关于存储过程的SQL补充总结前言近来碰到这样一个问题:在生产上导入的数据发现

华为鸿蒙HarmonyOS 5.1官宣7月开启升级! 首批支持名单公布

《华为鸿蒙HarmonyOS5.1官宣7月开启升级!首批支持名单公布》在刚刚结束的华为Pura80系列及全场景新品发布会上,除了众多新品的发布,还有一个消息也点燃了所有鸿蒙用户的期待,那就是Ha... 在今日的华为 Pura 80 系列及全场景新品发布会上,华为宣布鸿蒙 HarmonyOS 5.1 将于 7

Go学习记录之runtime包深入解析

《Go学习记录之runtime包深入解析》Go语言runtime包管理运行时环境,涵盖goroutine调度、内存分配、垃圾回收、类型信息等核心功能,:本文主要介绍Go学习记录之runtime包的... 目录前言:一、runtime包内容学习1、作用:① Goroutine和并发控制:② 垃圾回收:③ 栈和

Go语言中泄漏缓冲区的问题解决

《Go语言中泄漏缓冲区的问题解决》缓冲区是一种常见的数据结构,常被用于在不同的并发单元之间传递数据,然而,若缓冲区使用不当,就可能引发泄漏缓冲区问题,本文就来介绍一下问题的解决,感兴趣的可以了解一下... 目录引言泄漏缓冲区的基本概念代码示例:泄漏缓冲区的产生项目场景:Web 服务器中的请求缓冲场景描述代码

Go语言如何判断两张图片的相似度

《Go语言如何判断两张图片的相似度》这篇文章主要为大家详细介绍了Go语言如何中实现判断两张图片的相似度的两种方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 在介绍技术细节前,我们先来看看图片对比在哪些场景下可以用得到:图片去重:自动删除重复图片,为存储空间"瘦身"。想象你是一个

Go语言中Recover机制的使用

《Go语言中Recover机制的使用》Go语言的recover机制通过defer函数捕获panic,实现异常恢复与程序稳定性,具有一定的参考价值,感兴趣的可以了解一下... 目录引言Recover 的基本概念基本代码示例简单的 Recover 示例嵌套函数中的 Recover项目场景中的应用Web 服务器中

java对接海康摄像头的完整步骤记录

《java对接海康摄像头的完整步骤记录》在Java中调用海康威视摄像头通常需要使用海康威视提供的SDK,下面这篇文章主要给大家介绍了关于java对接海康摄像头的完整步骤,文中通过代码介绍的非常详细,需... 目录一、开发环境准备二、实现Java调用设备接口(一)加载动态链接库(二)结构体、接口重定义1.类型

VSCode设置python SDK路径的实现步骤

《VSCode设置pythonSDK路径的实现步骤》本文主要介绍了VSCode设置pythonSDK路径的实现步骤,包括命令面板切换、settings.json配置、环境变量及虚拟环境处理,具有一定... 目录一、通过命令面板快速切换(推荐方法)二、通过 settings.json 配置(项目级/全局)三、

MySQL 存储引擎 MyISAM详解(最新推荐)

《MySQL存储引擎MyISAM详解(最新推荐)》使用MyISAM存储引擎的表占用空间很小,但是由于使用表级锁定,所以限制了读/写操作的性能,通常用于中小型的Web应用和数据仓库配置中的只读或主要... 目录mysql 5.5 之前默认的存储引擎️‍一、MyISAM 存储引擎的特性️‍二、MyISAM 的主

Linux lvm实例之如何创建一个专用于MySQL数据存储的LVM卷组

《Linuxlvm实例之如何创建一个专用于MySQL数据存储的LVM卷组》:本文主要介绍使用Linux创建一个专用于MySQL数据存储的LVM卷组的实例,具有很好的参考价值,希望对大家有所帮助,... 目录在Centos 7上创建卷China编程组并配置mysql数据目录1. 检查现有磁盘2. 创建物理卷3. 创