jybase/esv7/es_test.go

package elastic

import (
	"log"
	"testing"
)

type AggregationsBucket struct {
	Key       string `json:"key"`
	Doc_count int    `json:"doc_count"`
	Count     struct {
		Value float64 `json:value`
	} `json:"count"`
}

func TestGet(t *testing.T) {
	q := `{
	  "query": {
	    "bool": {
	      "must": [
	        {
	          "term": {
	            "id": "64e6b70abc72bfca100f4b63"
	          }
	        }
	      ]
	    }
	  }
	}`
	NewEs("v7", "http://127.0.0.1:19805", 2, "elastic", "MsOCrY7Yct3sjVvB5gCd")
	//NewEs("v1", "http://192.168.3.206:9800", 2, "", "")
	list := Get("bidding", "bidding", q)
	log.Println(list)
}

func TestAnalyze(t *testing.T) {
	NewEs("v7", "http://192.168.3.241:9205,http://192.168.3.149:9200", 2, "", "")
	//NewEs("v1", "http://192.168.3.206:9800", 2, "", "")
	res := Analyze("软件中国", "bidding", "ik_smart")
	log.Println(res)
}