by Robin at 20240923
This commit is contained in:
parent
cb02d2f15c
commit
3f171d684c
|
@ -22,13 +22,14 @@ func ImportUserIdMap() {
|
||||||
}
|
}
|
||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
|
|
||||||
for i := 0; i < 100; i++ {
|
for i := 1; i < 100; i++ {
|
||||||
pathurl := fmt.Sprintf("/app/data_prep/file/user_id_map%v.txt", i)
|
|
||||||
go func(i int) {
|
go func(i int) {
|
||||||
fmt.Printf("Importing %dth", i)
|
fmt.Printf("Importing %dth", i)
|
||||||
|
pathurl := fmt.Sprintf("/app/data_prep/file/user_id_map%v.txt", i)
|
||||||
infile, err := os.Open(pathurl)
|
infile, err := os.Open(pathurl)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Printf("Open File Err : %v", err)
|
fmt.Printf("Open File Err : %v", err)
|
||||||
|
return
|
||||||
}
|
}
|
||||||
reader := bufio.NewReader(infile)
|
reader := bufio.NewReader(infile)
|
||||||
userIdMaps := make([]*dbstruct.UserIdMap, 0)
|
userIdMaps := make([]*dbstruct.UserIdMap, 0)
|
||||||
|
|
Loading…
Reference in New Issue