Блог

Привет, я создаю POST-запрос в GO, но он завершается до фактического завершения, например, я пытаюсь извлечь изображение docker, и это можно сделать с помощью curl следующим образом:

 curl -X POST https://address/images/create?fromImage=imagename 
  

это возвращает следующее

 {"status":"Pulling from imagename","id":"latest"}
{"status":"Already exists","progressDetail":{},"id":"3d30e94188f7"}
{"status":"Already exists","progressDetail":{},"id":"bf4e27765153"}
{"status":"Already exists","progressDetail":{},"id":"67280fd39fba"}
.... many of those
{"status":"Pull complete","progressDetail":{},"id":"21c062e2346f"}
{"status":"Digest: sha256:24f26a1344fca6d5ee1adcdsf2d01b20d7823c560ed9d2193466e36bd1f049088"}
{"status":"Pulling from imagename","id":"20161005"}
{"status":"Digest: sha256:f527dsfds88676eb25d8f7de5406f46cbc3a995345ddb4bb3d08fcf110458fe3cf"}
{"status":"Status: Downloaded newer image for imagename"}
  

и изображение успешно извлекается

но если я попытаюсь с go

 func PullImage(imagename string, uuid string) error {
logFields := log.Fields{

    "handler": "PullImage",
    "uuid":    uuid,
}

log.WithFields(logFields).Debugf("imagename:%v", imagename)

url := fmt.Sprintf("https://%s/images/create?fromImage%s", sconf.Docker.Endpoint, imagename)
req, err := http.NewRequest("POST", url, nil)

req.Header.Set("Content-Type", "application/json")
resp, err := client.Do(req)

log.WithFields(logFields).Infof("call url:%s", url)
if err != nil {
    log.WithFields(logFields).Errorf("Error in call url (%s) :%s", url, err)

    return errors.New(fmt.Sprintf("Error in call url (%s) :%s", url, err))
}


var pullresbody interface{}
err = json.NewDecoder(resp.Body).Decode(amp;pullresbody)
if err != nil {
    log.WithFields(logFields).Errorf("Could not unmarshal json: %s", err)
    return errors.New(fmt.Sprintf("Could not unmarshal json: %s", err))
}

    log.WithFields(logFields).Infof("response of url %s:% v", url, resp)
log.WithFields(logFields).Infof("response body:% v", pullresbody)
   return nil
  

}

затем я получаю это в журналах:

 map[status:Pulling from imagename]
  

и изображение не извлекается, поэтому соединение прерывается до реального завершения, как я могу это исправить?

Одновременно Decoder будет декодироваться только один объект из потока. Чтобы получить все объекты, вам понадобится что-то вроде

 var pullRespBody interface{}
dec := json.NewDecoder(resp.Body)
var err error
for err == nil {
    err = dec.Decode(amp;pullRespBody)
    // Check err...
    log.WithFields(logFields).Infof("response body:% v", pullRespBody)
    // Do something else with pullRespBody...
}
// Deal with err...