Commit 841d8d55 authored by 陈子龙's avatar 陈子龙

自动化运维 fix

parent 8768d335
......@@ -9,7 +9,6 @@ import (
"gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/vo/response"
"gitlab.wodcloud.com/smart-operation/so-operation-api/src/common/client"
"gitlab.wodcloud.com/smart-operation/so-operation-api/src/pkg/beagle/resp"
"os"
"os/exec"
"strings"
"time"
......@@ -309,18 +308,18 @@ func (h *HostManageSvc) ListStateHostManage(req request.StateHostManageReq) (err
}
//往hosts文件中写入主机组ip
f, err := os.OpenFile("/etc/ansible/hosts", os.O_APPEND|os.O_CREATE|os.O_RDWR|os.O_TRUNC, 0777)
if err != nil {
err = resp.FileExecError.WithError(err)
return
}
defer f.Close()
for _, v := range hostManageList {
_, err = f.Write([]byte(fmt.Sprintf("%s ansible_ssh_host=%s ansible_ssh_port=%s ansible_ssh_user=\"%s\" ansible_ssh_pass=\"%s\"\n", v.Ip, v.Ip, v.Port, v.UserName, v.Password)))
if err != nil {
return resp.FileExecError.WithError(err)
}
}
//f, err := os.OpenFile("/etc/ansible/hosts", os.O_APPEND|os.O_CREATE|os.O_RDWR|os.O_TRUNC, 0777)
//if err != nil {
// err = resp.FileExecError.WithError(err)
// return
//}
//defer f.Close()
//for _, v := range hostManageList {
// _, err = f.Write([]byte(fmt.Sprintf("%s ansible_ssh_host=%s ansible_ssh_port=%s ansible_ssh_user=\"%s\" ansible_ssh_pass=\"%s\"\n", v.Ip, v.Ip, v.Port, v.UserName, v.Password)))
// if err != nil {
// return resp.FileExecError.WithError(err)
// }
//}
for _, v := range hostManageList {
//状态检测
......@@ -471,7 +470,7 @@ func StatusDetection(ip string) (ipConn bool) {
var cmd *exec.Cmd
cmd = exec.Command("ansible", ip, "-m", "ping")
cmd = exec.Command("ansible", fmt.Sprintf("%s", ip), "-m", "ping")
output, err := cmd.Output()
if err != nil {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment