添加链接
link之家
链接快照平台
  • 输入网页链接,自动生成快照
  • 标签化管理网页链接
"github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/credentials" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/s3" tsgutils "github.com/typa01/go-utils" type AmazonClient struct { Region string AccessKeyID string // id SecretKey string // secret BucketName string UrlMain string UrlFolder string // format "/operation/upload/jinhaiyun/" FileType string //options Token string ACL string ContentType string // operatte outcome Session *session.Session FilePath string // after upload, this file path will exist , which is the internal path, not include bucket type ClientOpt struct { //ACL: 权限枚举 https://docs.aws.amazon.com/AmazonS3/latest/userguide/acl-overview.html#canned-acl ACL string ContentType string Token string type Option func(ops *ClientOpt) //For access controller func WithAcl(acl string) Option { return func(ops *ClientOpt) { ops.ACL = acl func WithContentType(contentType string) Option { return func(ops *ClientOpt) { ops.ContentType = contentType func WithToken(token string) Option { return func(ops *ClientOpt) { ops.Token = token func NewAmazonClient(region, accessKeyID, secretKey, bucketName, urlMain, urlFolder,fileType string, options ...Option) *AmazonClient { optionsItem := new(ClientOpt) for i := range options { options[i](optionsItem) client := new(AmazonClient) client.ACL = optionsItem.ACL client.ContentType = optionsItem.ContentType client.Token = optionsItem.Token client.Region = region client.AccessKeyID = accessKeyID client.SecretKey = secretKey client.BucketName = bucketName client.UrlMain = urlMain client.UrlFolder = urlFolder client.FileType = fileType sess, err := session.NewSession(&aws.Config{ Region: aws.String(client.Region), //桶所在的区域 Credentials: credentials.NewStaticCredentials(client.AccessKeyID, client.SecretKey, client.Token), //sts的临时凭证 if err != nil { panic(err) client.Session = sess return client func (this *AmazonClient) Upload(buffer []byte) (url string, err error) { filePath := this.UrlFolder + tsgutils.GUID() + this.FileType this.FilePath=filePath _, err = s3.New(this.Session).PutObject(&s3.PutObjectInput{ Bucket: aws.String(this.BucketName), //桶名 Key: aws.String(filePath), //文件的目录+文件名 Body: bytes.NewReader(buffer), ACL: aws.String("public-read"), //ContentType: aws.String("image/jpeg"), if err != nil { panic(err.Error()) url = this.UrlMain + filePath return func (this *AmazonClient) Download() (fileByte []byte, err error) { out, err := s3.New(this.Session).GetObject(&s3.GetObjectInput{ Bucket: aws.String("moole-verify-img-bucket-dev"), //桶名 Key: aws.String(this.FilePath), defer out.Body.Close() if err != nil { panic(err.Error()) scanner := bufio.NewScanner(out.Body) for scanner.Scan() { fileByte = scanner.Bytes() return
package common_use
import (
	"api_quant_manage_system/utils"
	"github.com/spf13/viper"
	"sync"
var xlsAWSClient *utils.AmazonClient
func InitxlsClient(v *viper.Viper)*utils.AmazonClient{
	if xlsAWSClient ==nil{
		once:=sync.Once{}
		once.Do(func() {
			if xlsAWSClient ==nil{
				xlsAWSClient =utils.NewAmazonClient(
					v.GetString("region"),
					v.GetString("access_key_id"),
					v.GetString("secret_key"),
					v.GetString("bucket_name"),
					v.GetString("url_main"),
					v.GetString("url_folder"),
					v.GetString("file_type"),
					utils.WithToken(v.GetString("token")),
					utils.WithAcl(v.GetString("acl")),
					utils.WithAcl(v.GetString("content_type")),
	return xlsAWSClient
func GetXlsAwsClient() *utils.AmazonClient {
	return xlsAWSClient
                                    在本文中,我们将探讨如何使用Golang编程语言和AWS SDK来操作AWS S3对象存储。AWS SDK提供了丰富的功能和API,使我们可以方便地进行云存储的管理和操作。除了上传文件之外,AWS SDK还提供了许多其他功能,如下载文件、列出存储桶中的对象、删除对象等等。接下来,我们设置要上传的本地文件的路径和S3存储桶的名称。最后,我们使用S3服务客户端的。在上面的示例中,我们首先创建了一个新的AWS会话,并指定了所在的区域。请注意,上述代码中的区域和存储桶名称是示例值,需要根据您的实际情况进行替换。
对象分片上传
对象的分片上传优势
使用分段上传可提供以下优势:建议您按以下方式使用分段上传:分段上分为三个步骤:开始上传、上传对象分段,以及在上传所有分段后完成分段上传。当您发送请求以开始分段上传时,Amazon S3 将返回具有上传 ID 的响应,此 ID 是分段上传的唯一标识符。无论您何时上传分段、列出分段、完成上传或停止上传,您都必须包括此上传 ID。如果您想要提供描述已上传的对象的任何元数据,必须在请求中提供它以开始分段上传。上传分段时,除了指定上传 ID,还必须指定
                                    S3下载管理器确定文件是否可以拆分为更小的部分并并行下载。您可以自定义并行下载的数量和下载部分的大小。S3上传管理器确定文件是否可以拆分为更小的部分并并行上传。您可以自定义并行上传的数量和上传部分的大小。上传和下载管理器可以分解大型对象,以便可以将它们分成多个部分并行传输。这使得恢复中断的传输变得容易。下载的文件d_2.jpg如图。...
                                    若不想升级go1.20,可以使用v1版本。官方推荐版本,需要go版本>=1.20。: 访问存储桶所需的AccessKey。: 访问存储桶所需的KeyID。: 存储桶所在区域,例。
首先,创建一个aws账户,可以在这里创建。
创建账户后,进入控制台,在storage分类中选择s3 服务。
在s3控制台,创建一个新的bucket,命名友好一些,因为bucket命名将会成为url的一部分。
bucket创建完以后,可以用来存储文件,此处即用来存储图片。
二、上传图片编码
开始之前,我们需要先从github上安装aws sdk,可以通过下边代码在终端上执行来完成。
$ go get github.com/aws/aws-sdk-go/...