How to upload the multipart file directly to the AWS S3 bucket using echo framework?

[sriramkp]

I want to upload the bigger files (videos) to AWS S3 bucket directly from echo file handler than saving the file to local drive and upload to S3 bucket as a multi part request. In the below code, I copied the file content to bytes.Buffer, but I am not sure its correct or not.

Kindly help me!

func (h *fileHandler) UploadFile(c echo.Context) error {

	// Source
	file, err := c.FormFile("file")
	if err != nil {
		return err
	}
	src, err := file.Open()
	if err != nil {
		return err
	}
	defer src.Close()

	// Destination
	var buf bytes.Buffer
	if _, err := io.Copy(&buf, src); err != nil {
		return err
	}
	
        session.Must(session.NewSession(&aws.Config{Region: aws.String(region)}))
	uploader := s3manager.NewUploader(session, func(u *s3manager.Uploader) {
		u.PartSize = 5 * 1024 * 1024 // The minimum/default allowed part size is 5MB
		u.Concurrency = 2            // default is 5
	})

        upParams := &s3manager.UploadInput{
		        Bucket: aws.String(repo.bucket),
		        Key:    aws.String(repo.accessKeyId),
		        Body:   bytes.NewReader(buf.Bytes()),
	        }
        
        result, err := uploader.Upload(upParams)
        if err != nil {
        
        return "", fmt.Errorf("failed to upload file, %v", err)
        }

	return c.JSON(http.StatusOK, transport.Status{Code: http.StatusOK, Msg: "File Uploaded successfully."})
}

[aldas]

Combine
start of this https://echo.labstack.com/cookbook/file-upload/
with that https://github.com/awsdocs/aws-doc-sdk-examples/blob/master/go/example_code/s3/s3_upload_object.go

also you could modify this Gin example for Echo https://medium.com/wesionary-team/aws-sdk-for-go-and-uploading-a-file-using-s3-bucket-df7425317a40

or use SDK example https://docs.aws.amazon.com/sdk-for-go/api/service/s3/s3manager/#example_NewUploader_overrideReadSeekerProvider

	file, err := c.FormFile("file")
	if err != nil {
		return err
	}
	src, err := file.Open()
	if err != nil {
		return err
	}
	defer src.Close()
	sess := session.Must(session.NewSession())

	uploader := s3manager.NewUploader(sess, func(u *s3manager.Uploader) {
		// Define a strategy that will buffer 25 MiB in memory
		u.BufferProvider = s3manager.NewBufferedReadSeekerWriteToPool(25 * 1024 * 1024)
	})

	_, err := uploader.Upload(&s3manager.UploadInput{
		Bucket: aws.String("examplebucket"),
		Key:    aws.String("largeobject"),
		Body:   src,
	})

[sriramkp]

This is the best community I ever found to get quick answers!

Thanks a lot!