|
|
@@ -148,7 +148,6 @@ func insertLogInfo(logInfo *logInfo){
|
|
|
Data interface{}
|
|
|
}
|
|
|
if logInfo.RespBody != ""{
|
|
|
- fmt.Println(logInfo.RespBody)
|
|
|
err = json.Unmarshal([]byte(logInfo.RespBody), &respBodyObj)
|
|
|
if err != nil{
|
|
|
fmt.Println("json.Unmarshal 错误", err.Error())
|
|
|
@@ -165,7 +164,6 @@ func insertLogInfo(logInfo *logInfo){
|
|
|
}
|
|
|
logInfo.CostTime = float64(logInfo.RespTime.Sub(logInfo.ReqTime).Seconds())
|
|
|
|
|
|
- // 保存轨迹
|
|
|
cqlformat := `insert into
|
|
|
log_info(app_name, req_date, req_time, req_method, req_url, req_proto, req_ua, req_referer, req_post_data, resp_time, resp_body, resp_code, resp_msg, resp_data, cost_time)
|
|
|
values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?);`
|
|
|
@@ -174,7 +172,7 @@ func insertLogInfo(logInfo *logInfo){
|
|
|
batch := session.NewBatch(gocql.UnloggedBatch) // 应该批量插入多条，例如20条
|
|
|
batch.Query(cqlformat, __appName, reqDate, logInfo.ReqTime.Format("2006-01-02 15:04:05"), logInfo.ReqMethod, logInfo.ReqUrl, logInfo.ReqProto, logInfo.ReqUa, logInfo.ReqReferer, logInfo.ReqPostData, logInfo.RespTime.Format("2006-01-02 15:04:05"), logInfo.RespBody, logInfo.RespCode, logInfo.RespMsg, logInfo.RespData, logInfo.CostTime)
|
|
|
if err := session.ExecuteBatch(batch); err != nil {
|
|
|
- fmt.Println("批量插入轨迹错误:", err)
|
|
|
+ fmt.Println("批量插入日志错误:", err)
|
|
|
return
|
|
|
}
|
|
|
}
|
huangrf