Method BuildIndexByBuck

models/ElasticSearchModel.go:343–367

通过bulk，批量创建/更新索引

(data []ElasticSearchData)

//通过bulk，批量创建/更新索引
func (this *ElasticSearchClient) BuildIndexByBuck(data []ElasticSearchData) (err error) {
	var bodySlice []string
	if len(data) > 0 {
		for _, item := range data {
			action := fmt.Sprintf(`{"index":{"_index":"%v","_type":"%v","_id":%v}}`, this.Index, this.Type, item.Id)
			bodySlice = append(bodySlice, action)
			bodySlice = append(bodySlice, util.InterfaceToJson(item))
		}
		api := this.Host + "_bulk"
		body := strings.Join(bodySlice, "\n") + "\n"
		if helper.Debug {
			helper.Logger.Info("批量更新索引请求体")
			helper.Logger.Info(body)
		}
		if resp, errResp := this.post(api).Body(body).Response(); errResp != nil {
			err = errResp
		} else {
			if resp.StatusCode >= http.StatusMultipleChoices || resp.StatusCode < http.StatusOK {
				b, _ := ioutil.ReadAll(resp.Body)
				err = errors.New(resp.Status + "；" + string(b))
			}
		}
	}
	return
}

//创建索引
func (this *ElasticSearchClient) BuildIndex(es ElasticSearchData) (err error) {