golang 작업 Elasticsearch
2215 단어 go
데모는 다음과 같습니다.
package main
import (
"fmt"
"context"
"github.com/olivere/elastic"
"encoding/json"
)
type Map map[string]interface{}
func (m Map) SetVal(key string, val interface{}) {
if val == nil {
delete(m, key)
} else {
m[key] = val
}
}
func (m Map) GetVal(key string) interface{} {
value, ok := m[key]
if !ok {
return nil
} else {
return value
}
}
func EsGet() {
Client, err := elastic.NewClient(elastic.SetURL("http://127.0.0.1:9200"))
if err != nil {
fmt.Println(" es")
return
}
// id
get, err := Client.Get().Index("product_index").Id("19523").Do(context.Background())
if err != nil {
fmt.Println(" ", err)
return
}
//
query := elastic.NewMatchQuery("title", " ")
mi, err := Client.Search().Index("product_index").Query(query).From(0).Size(10).Do(context.Background())
if err != nil {
return
}
source := get.Source
for _, h := range mi.Hits.Hits {
var dict db.Map
err = json.Unmarshal(h.Source, &dict)
if err != nil {
fmt.Println("MatchQuery ", err)
return
}
fmt.Println(dict.GetVal("title"))
}
var data Map
err = json.Unmarshal(source, &data)
if err != nil {
return
}
fmt.Println("data", data.GetVal("title"))
fmt.Println(string(source))
// must sql and ,terms in
boolQuery := elastic.NewBoolQuery()
boolQuery.Must(elastic.NewTermQuery("buyer_id", 1), elastic.NewTermsQuery("type", 100,400))
orderResp, err := Client.Search().Index("order_index").Sort("tid", false).Query(boolQuery).From(0).Size(10).Do(context.Background())
if err != nil {
fmt.Println(" ", err)
return
}
for _, o := range orderResp.Hits.Hits {
var order db.Order
err = json.Unmarshal(o.Source, &order)
if err != nil {
fmt.Println("eeee", err)
}
}
fmt.Println(" ", len(orderResp.Hits.Hits))
func main() {
EsGet()
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Go Fiber 및 PlanetScale로 REST API 구축 - 4부다시 사용자 핸들러에 UpdateUser라는 새 함수를 추가합니다. 업데이트 사용자를 main.go에 등록 이제 응용 프로그램을 다시 실행하십시오. 이전에 생성한 사용자를 업데이트합니다. 응답 사용자가 존재하지 않을...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.