Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- const (
- awsBucketRegion = "YOUR-BUCKET-REGION"
- awsBucketName = "YOUR-BUCKET-NAME"
- partSize = 5 * 1024 * 1024
- maxRetry = 1
- )
- // AddFileS3 add a new file to the multipart.
- func AddFileS3Compressed(fileName string, reader io.ReadCloser) (*s3manager.UploadOutput, error) {
- // Create a single AWS session (we can re use this if we're uploading many files)
- cfg := &aws.Config{
- Region: aws.String(awsBucketRegion),
- MaxRetries: aws.Int(maxRetry),
- }
- // with logger need to be added.
- svc := session.Must(session.NewSession(cfg))
- uploader := s3manager.NewUploader(svc)
- uploader.PartSize = partSize
- result, err := uploader.Upload(&s3manager.UploadInput{
- Body: reader,
- Bucket: aws.String(awsBucketName),
- Key: aws.String(fileName),
- })
- if err != nil {
- return nil, err
- }
- return result, nil
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement