downloads3data.go

func downloadS3Data(fetcher S3Fetcher, bucket string, key string) ([]byte, error) {
       results, err := fetcher.GetObject(&s3.GetObjectInput{
                 Bucket: aws.String(bucket),
                 Key:    aws.String(key),
       })

       if err != nil {
                 return nil, err
       }
       defer results.Body.Close()

       buf := bytes.NewBuffer(nil)
       if _, err := io.Copy(buf, results.Body); err != nil {
                 return nil, err
       }
       return buf.Bytes(), nil
}