func processRecords()

in workload-management/s3-trigger-ecs-task/s3-file-processor/main.go [68:77]


func processRecords(records []*utils.Record, tmpFile *os.File) {
	response, err := utils.BatchWriteItem(records)
	if err != nil{
		failure("Error while saving data to dynamodb")
	}
	err = utils.AppendFile(response, tmpFile)
	if err != nil {
		failure("Error while appending output file")
	}
}