func CopyS3ToTmp()

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
}