diff --git a/src/service/task_manage.go b/src/service/task_manage.go index f64e1542e535bd01b6c1a0ae1ea5fe31385de010..3b57f3ec04e36e8dbe32945cb219c2d48a0eeab0 100644 --- a/src/service/task_manage.go +++ b/src/service/task_manage.go @@ -203,15 +203,17 @@ func (t *TaskManageSvc) ExecScript(req request.ExecScriptReq) (data map[string]i } req.Script = string(obj) } + var scripts []map[string]interface{} var script map[string]interface{} j2, err := yaml.YAMLToJSON([]byte(req.Script)) if err != nil { return nil, resp.YamlAnalysisError.WithError(err) } - err = json.Unmarshal(j2, &script) + err = json.Unmarshal(j2, &scripts) if err != nil { return nil, resp.MarshalError.WithError(errors.New("yaml格式错误")) } + script = scripts[0] script["host"] = fmt.Sprintf("%s%d", AnsibleGroup, req.HostGroupId) j, err := json.Marshal(script) if err != nil { @@ -254,6 +256,8 @@ func (t *TaskManageSvc) ExecScript(req request.ExecScriptReq) (data map[string]i } stdout, err := cmd.StdoutPipe() if err != nil { + fmt.Println("执行出错:", err) + fmt.Println("stdout:", stdout) return nil, resp.CmdExecError.WithError(err) } outputBuf := bufio.NewReader(stdout)