- package main
-
- import (
- "fmt"
- "strings"
- "github.com/ivancevich/s3-url-upload"
- "os"
- )
-
- func AddFileToS3(url string){
- fmt.Println(url)
- fmt.Printf("Upload to s3 start\n")
- var media []string
- media = append(media,url)
- config := s3urlupload.Config{
- AwsAccessKey: "11111111",
- AwsSecretKey: "11111111",
- AwsS3Endpoint: "s3-us-east-2.amazonaws.com", // e.g. "s3-us-west-2.amazonaws.com"
- AwsS3Bucket: "images",
- Workers: 4,
- GetFilePath: func(url string) string {
- fileurl:=strings.Replace(url, "https://", "", 1 )
- fmt.Println("https://xxx-images"+".s3.us-east-2.amazonaws.com/"+fileurl)
- return fileurl
- },
- }
-
- s3UrlUpload := s3urlupload.Init(config)
- results := s3UrlUpload.Run(media...)
-
- for r := range results {
- if r.Error != nil {
- fmt.Printf("%+v\n", r)
- }
- }
- fmt.Printf("Upload to s3 finished\n")
- fmt.Printf("\n")
- }
-
- func main(){
- AddFileToS3(os.Args[1])
- }