go操作aws s3记录

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
}

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
}