goroutines запускают post api параллельно со списком данных

Question

Это мой первый опыт работы с go, я пришел из python фона и пытаюсь запустить этот пост api (https://reqres.in/api/users) параллельно, используя goroutines с другой набор почтовых данных, который является переменной jsonStr в этом коде.

Любая помощь, высоко ценимая для запуска этого API параллельно со списком данных

Мои данные

data = [{"name": "bonny gaud", "movies": ["Terminator", "Transformer"], {"name": "Sarah palin", "movies": ["Нет страны для старый "," Джеймс Бонд "]}

Мой код:

package main

import (
    "fmt"
    "io/ioutil"
    "net/http"
    "time"
    "bytes"
)

func main() {
    start := time.Now()
    url := "https://reqres.in/api/users"
    fmt.Println("URL:>", url)
    var jsonStr = []byte(`{"name": "paul rudd", "movies": ["I Love You Man", "Role Models"] }`)
    req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonStr))
    req.Header.Set("X-Custom-Header", "myvalue")
    req.Header.Set("Content-Type", "application/json")

    client := &http.Client{}
    resp, err := client.Do(req)
    if err != nil {
        panic(err)
    }
    defer resp.Body.Close()

    fmt.Println("response Status:", resp.Status)
    fmt.Println("response Headers:", resp.Header)
    body, _ := ioutil.ReadAll(resp.Body)
    fmt.Println("response Body:", string(body))

    fmt.Print("Everything:", time.Since(start))
    fmt.Print(string(body))

}

Answer 1

Вы можете использовать waitGroup или errGroup. Вот пример:

package main

import (
    "bytes"
    "fmt"
    "golang.org/x/sync/errgroup"
    "io/ioutil"
    "net/http"
    "time"
)

func main() {
    dataSets := []string{`{"name": "paul rudd", "movies": ["I Love You Man", "Role Models"] }`,
        `{"name": "paul rudd", "movies": ["I Love You Man", "Role Models"] }`}

    var eg errgroup.Group

    client := http.DefaultClient
    for _, jsonStr := range dataSets {
        eg.Go(func() error {
            return callClient(client, jsonStr)
        })
    }

    if err := eg.Wait(); err != nil {
        fmt.Printf("Encountered error: %v", err)
    }

    fmt.Println("Successfully finished.")
}

func callClient(client *http.Client, jsonStr string) error {
    start := time.Now()
    url := "https://reqres.in/api/users"
    fmt.Println("URL:>", url)

    req, err := http.NewRequest("POST", url, bytes.NewBuffer([]byte(jsonStr)))
    req.Header.Set("X-Custom-Header", "myvalue")
    req.Header.Set("Content-Type", "application/json")

    resp, err := client.Do(req)
    if err != nil {
        return fmt.Errorf("send request: %w", err)
    }
    defer resp.Body.Close()

    fmt.Println("response Status:", resp.Status)
    fmt.Println("response Headers:", resp.Header)

    body, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        return fmt.Errorf("read body: %w", err)
    }

    fmt.Println("response Body:", string(body))

    fmt.Print("Everything:", time.Since(start))
    fmt.Print(string(body))

    return nil
}