diff --git a/importfunc/import_user_id_map.go b/importfunc/import_user_id_map.go index f6ce888..863737e 100644 --- a/importfunc/import_user_id_map.go +++ b/importfunc/import_user_id_map.go @@ -22,13 +22,14 @@ func ImportUserIdMap() { } ctx := context.Background() - for i := 0; i < 100; i++ { - pathurl := fmt.Sprintf("/app/data_prep/file/user_id_map%v.txt", i) + for i := 1; i < 100; i++ { go func(i int) { fmt.Printf("Importing %dth", i) + pathurl := fmt.Sprintf("/app/data_prep/file/user_id_map%v.txt", i) infile, err := os.Open(pathurl) if err != nil { fmt.Printf("Open File Err : %v", err) + return } reader := bufio.NewReader(infile) userIdMaps := make([]*dbstruct.UserIdMap, 0)