Method BuildIndexByBuck

models/elasticsearch.go:400–434

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

(data []ElasticSearchData)

//通过bulk，批量创建/更新索引
func (this *ElasticSearchClient) BuildIndexByBuck(data []ElasticSearchData) (err error) {
	if !this.On {
		return
	}

	now := time.Now()
	var bodySlice []string
	if len(data) > 0 {
		var _id string
		for _, item := range data {
			if item.BookId > 0 { //书籍的id大于0，表示这个数据是文档的数据，否则是书籍的数据
				_id = fmt.Sprintf("doc_%v", item.Id)
			} else {
				_id = fmt.Sprintf("book_%v", item.Id)
			}
			action := fmt.Sprintf(`{"index":{"_index":"%v","_type":"%v","_id":"%v"}}`, this.Index, this.Type, _id)
			bodySlice = append(bodySlice, action)
			bodySlice = append(bodySlice, util.InterfaceToJson(item))
		}
		api := this.Host + "_bulk"
		body := strings.Join(bodySlice, "\n") + "\n"
		if orm.Debug {
			beego.Info("批量更新索引请求体")
			beego.Info(body)
		}
		err = utils.HandleResponse(this.post(api).Body(body).Response())
	}
	d := time.Since(now)
	if d > time.Duration(this.Timeout) {
		// 生成索引时长过长，休眠一小段时间
		beego.Info("sleep second", (time.Duration(this.Timeout/2) * time.Second).Seconds())
		time.Sleep(time.Duration(this.Timeout/2) * time.Second)
	}
	return
}

// 设置书籍的公有和私有，需要根据文档同时更新文档的公有和私有
func (this *ElasticSearchClient) SetBookPublic(bookId int, public bool) (err error) {