From eb6f08d1eea2430383ad486eca9d3a509db344bf Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期二, 17 十二月 2019 10:04:21 +0800
Subject: [PATCH] 装配目标
---
insertdata/EsClient.go | 17 +++++++++++------
1 files changed, 11 insertions(+), 6 deletions(-)
diff --git a/insertdata/EsClient.go b/insertdata/EsClient.go
index 7a72deb..4e7dd31 100644
--- a/insertdata/EsClient.go
+++ b/insertdata/EsClient.go
@@ -1,6 +1,8 @@
package insertdata
import (
+ "basic.com/valib/logger.git"
+ "bytes"
"encoding/json"
"errors"
"fmt"
@@ -10,7 +12,6 @@
"strconv"
"strings"
"time"
- "bytes"
)
type Reps struct {
@@ -128,7 +129,7 @@
}
**/
-func EsReq(method string, url string, parama []byte) (err error) {
+func EsReq(method string, url string, parama []byte) (maps map[string]interface{},err error) {
timeout := time.Duration(10 * time.Second)
client := http.Client{
Timeout: timeout,
@@ -138,13 +139,13 @@
if err != nil {
fmt.Println("build request fail !")
- return err
+ return nil, err
}
resp, err := client.Do(request)
if err != nil{
fmt.Println("request error: ", err)
- return err
+ return nil,err
}
defer resp.Body.Close()
@@ -153,9 +154,13 @@
if err != nil {
fmt.Println(err)
}
-
+ decoder := make(map[string]interface{})
+ if err := json.Unmarshal([]byte(string(body)), &decoder); err != nil {
+ return nil, err
+ }
fmt.Println(string(body))
- return nil
+ logger.Info(string(body))
+ return decoder ,nil
}
--
Gitblit v1.8.0