in workload-management/s3-trigger-ecs-task/s3-file-processor/utils/FileHelper.go [192:212]
func CopyS3ToTmp() (*string, error) {
s3InputFilePath := fmt.Sprintf("s3://%s/%s", os.Getenv(S3BucketName), os.Getenv(S3Key))
splitFileDirectory := fmt.Sprintf("/tmp/%s", os.Getenv(StatusKey))
os.RemoveAll(splitFileDirectory)
os.MkdirAll(splitFileDirectory, os.ModePerm)
// Copy files from S3 to EFS
splitCommand := fmt.Sprintf("aws s3 cp %s %s", s3InputFilePath, InputFilePath)
cmd:=exec.Command("sh", "-c", splitCommand)
cmd.Stdout = os.Stdout
cmd.Stderr = os.Stderr
err := cmd.Run()
if err != nil {
return nil, err
}
return &InputFilePath, nil
}