in workload-management/s3-trigger-ecs-task/s3-file-processor/main.go [111:139]
func initialize() (*os.File, *os.File, error) {
// Get input file
inputFilePath, err := utils.CopyS3ToTmp()
if err != nil {
return nil, nil, err
}
inputFile, err := utils.GetFile(*inputFilePath)
if err != nil {
log.Printf("Error while getting the input file " + err.Error())
return nil, nil, err
}
// Delete and recreate output file
outputFile, err := utils.TruncateFile(utils.GetOutputFile(true))
if err != nil {
log.Printf("Error while creating output file " + err.Error())
return nil, nil, err
}
// Delete and recreate table
err = utils.RecreateTable()
if err != nil {
log.Printf("Error while creating dynamodb tables " + err.Error())
return nil, nil, err
}
return inputFile, outputFile, nil
}