go操作aws s3
创始人
2024-11-29 17:06:30

v2

官方推荐版本,需要go版本>=1.20

安装

go get github.com/aws/aws-sdk-go-v2 go get github.com/aws/aws-sdk-go-v2/config go get github.com/aws/aws-sdk-go-v2/service/s3 

必要参数

bucket: 存储桶的名称

Region: 存储桶所在区域,例us-east-1

accessKeyID: 访问存储桶所需的KeyID

secretAccessKey: 访问存储桶所需的AccessKey

如何获取accessKeyIDsecretAccessKey:指南

var ( 	s3Client *s3.Client 	bucket   = "yourbucketname" )  func InitS3Client() { 	accessKeyID := "xxxxx" 	secretAccessKey := "xxxxx"  	cfg, err := config.LoadDefaultConfig(context.TODO(), 		config.WithRegion("us-east-1"), 		config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider(accessKeyID, secretAccessKey, "")), 	) 	if err != nil { 		log.Fatalf("unable to load SDK config, %v", err) 	}  	s3Client = s3.NewFromConfig(cfg) }  func UploadToS3(filePath, fileName, mimeType string) (string, error) { 	file, err := os.Open(filePath) 	if err != nil { 		return "", fmt.Errorf("failed to open file %q, %v", filePath, err) 	} 	defer file.Close()  	_, err = s3Client.PutObject(context.TODO(), &s3.PutObjectInput{ 		Bucket:      aws.String(bucket), 		Key:         aws.String(fileName), 		Body:        file, 		ContentType: aws.String(mimeType), 	}) 	if err != nil { 		return "", fmt.Errorf("failed to upload file to S3, %v", err) 	}  	return fmt.Sprintf("https://%s.s3.amazonaws.com/%s", bucket, fileName), nil } 

若不想升级go1.20,可以使用v1版本

v1

安装

go get github.com/aws/aws-sdk-go 
var ( 	s3Client *s3.S3 	bucket   = "yourbucketname" )  func InitS3Client() { 	accessKeyID := "xxxxx" 	secretAccessKey := "xxxxx"  	sess, err := session.NewSession(&aws.Config{ 		Region:      aws.String("us-east-1"), 		Credentials: credentials.NewStaticCredentials(accessKeyID, secretAccessKey, ""), 	}) 	if err != nil { 		log.Fatalf("unable to create AWS session, %v", err) 	}  	s3Client = s3.New(sess) }  func UploadToS3(content []byte, fileName, mimeType string) (string, error) { 	_, err := s3Client.PutObject(&s3.PutObjectInput{ 		Bucket:      aws.String(bucket), 		Key:         aws.String(fileName), 		Body:        bytes.NewReader(content), 		ContentType: aws.String(mimeType), 	}) 	if err != nil { 		return "", fmt.Errorf("failed to upload file to S3, %v", err) 	}  	return fmt.Sprintf("https://%s.s3.amazonaws.com/%s", bucket, fileName), nil } 

相关内容

热门资讯

四部门印发行动方案,促进人工智... 近日,国家能源局会同国家发展改革委、工业和信息化部、国家数据局印发《关于促进人工智能与能源双向赋能的...
瞄准8时13分!一起看发射场准... 我国将于5月11日8时13分发射天舟十号货运飞船。目前,长征七号遥十一运载火箭已完成推进剂加注。 距...
天舟十号货运飞船点火发射 今天上午,搭载天舟十号货运飞船的长征七号遥十一运载火箭,在我国文昌航天发射场点火发射。
原创 微... 前段时间 iOS 微信发布了 8.0.73 正式版,安卓微信发布了 8.0.72 测试版,这次的更新...
任正非罕见出镜:华为芯片基础技... 感谢IT之家网友 的线索投递! 5 月 10 日消息,在 5 月 8 日播出的《新闻联播》节目中,...