- go调用olivere包操作elasticsearch获取原始数据
核心代码如下:
//这里是查询条件
boolQ := elastic.NewBoolQuery()
//boolQ.Filter(elastic.NewRangeQuery("saveTime").Gte(begin))
res,err := this.deviceDBClient.Search("索引名称").
Size(10000).
Query(boolQ).
//Sort("saveTime",true). //排序
Do(context.Background())
if err != nil{
fmt.Println("读取失败",err)
}
//开始读取原始数据
for _,val := range res.Hits.Hits{
t := DevicePo.JieShouPo{} //数据的主体对象
err := json.Unmarshal(val.Source,&t)
fmt.Println(val.Index,val.Id,t.SaveTime,err)
}



