把es插入路径换成配置文件里的

panlei

2019-07-15 ca177f11067d4886e615a2179e943ed6acc687b4

把es插入路径换成配置文件里的

 config/conf.yml

@@ -1 +1,3 @@
photoUrl: "http://192.168.1.182:6333/submit"
videopersons: "http://192.168.1.182:9200/videopersons/perVideoPicture"

personaction: "http://192.168.1.182:9200/personaction/perVideoAction"

 insertdata/insertDataToEs.go

@@ -19,10 +19,12 @@
    "ruleprocess/util"
)

var weedfsUrl string
var weedfsUrl,videoPersonUrl,personAction string

type conf struct {
    PhotoUrl string `yaml:"photoUrl"`
    Videopersons string `yaml:"videopersons"`
    Personaction string `yaml:"personaction"`
}

func init() {
@@ -35,6 +37,8 @@
    //把yaml形式的字符串解析成struct类型
    yaml.Unmarshal(data, &c)
    weedfsUrl = c.PhotoUrl
    videoPersonUrl = c.Videopersons
    personAction = c.Personaction
}

// 人脸的数据结构
@@ -202,7 +206,7 @@
                logger.Info("json parse error ", err)
                return
            }
            err1 := EsReq("POST", "http://192.168.1.182:9200/videopersons/perVideoPicture", requstbody)
            err1 := EsReq("POST", videoPersonUrl, requstbody)
            if err1 != nil {
                logger.Error("上传ES出错！---", err1)
            }
@@ -271,7 +275,7 @@
            logger.Info("json parse error ", err)
            return
        }
        err1 := EsReq("POST", "http://192.168.1.182:9200/videopersons/perVideoPicture", requstbody)
    err1 := EsReq("POST", videoPersonUrl, requstbody)
        if err1 != nil {
            logger.Error("上传ES出错！---", err1)
        }
@@ -355,7 +359,7 @@
            return

        }
        err = EsReq("POST", "http://192.168.1.182:9200/personaction/perVideoAction", requstbody)
        err = EsReq("POST", personAction, requstbody)
        if err != nil {
            logger.Error("往ES插入数据失败", err)
        } else {
@@ -425,7 +429,7 @@
        return

    }
    err = EsReq("POST", "http://192.168.1.182:9200/personaction/perVideoAction", requstbody)
    err = EsReq("POST", personAction, requstbody)
    if err != nil {
        logger.Error("往ES插入数据失败", err)
    } else {
@@ -433,6 +437,7 @@
        //os.Exit(1)
    }
}

// 获取本机ip
func GetLocalIP() (ipv4 string, err error) {
    var (