|
@ -191,7 +191,7 @@ func (the *ESHelper) BulkWrite(index, reqBody string) { |
|
|
if res.StatusCode != 200 && res.StatusCode != 201 { |
|
|
if res.StatusCode != 200 && res.StatusCode != 201 { |
|
|
log.Panicf("es 写入失败,err=%s \n body=%s", string(respBody), reqBody) |
|
|
log.Panicf("es 写入失败,err=%s \n body=%s", string(respBody), reqBody) |
|
|
} |
|
|
} |
|
|
log.Printf("es 写入[%s],完成,res=%s ", index, reqBody) |
|
|
log.Printf("es 写入[%s],完成,res=%s ", index, respBody) |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|