使用gin作为api。
它的路线。走吧
func Init(api *gin.Engine) {
r := api.Group("/v1")
r.GET("/sites/search/:url", site.Search)
}
在控制器文件中,要使用go elasticsearch搜索es数据。
import (
"context"
"github.com/myapp/common/elasticsearch"
)
func Search(ctx *gin.Context) {
var data bool
data = GetES(ctx.Request.Context())
}
func GetES(ctx context.Context) bool {
var (
r map[string]interface{}
buf bytes.Buffer
)
var buf bytes.Buffer
query := map[string]interface{}{
"query": map[string]interface{}{
"match": map[string]interface{}{
"title": "test",
},
},
}
if err := json.NewEncoder(&buf).Encode(query); err != nil {
log.Fatalf("Error encoding query: %s", err)
}
res, err := elasticsearch.ESClient.Search(
elasticsearch.ESClient.Search.WithContext(ctx),
elasticsearch.ESClient.Search.WithIndex("indexname"),
elasticsearch.ESClient.Search.WithBody(&buf),
elasticsearch.ESClient.Search.WithTrackTotalHits(true),
)
// ...
}
电流 go-elasticsearch
的初始化方法正在使用 ctx context.Context
在公共文件中:
import (
"context"
elasticsearch "github.com/elastic/go-elasticsearch/v8"
"github.com/elastic/go-elasticsearch/v8/esapi"
)
func Init(ctx context.Context) {
var (
ESClient = *elasticsearch.Client
)
// ...
res, err := esapi.InfoRequest{}.Do(ctx, ESClient)
// ...
}
如果使用 req *http.Request
在控制器中 Search
函数,可以成功调用数据。但杜松子酒 ctx *gin.Context
将导致错误:
runtime error: invalid memory address or nil pointer dereference
/usr/local/go/src/runtime/panic.go:199 (0x44470b)
panicmem: panic(memoryError)
/usr/local/go/src/runtime/signal_unix.go:394 (0x444548)
sigpanic: panicmem()
/application/site/controller.go:100 (0xe9afea)
GetES: elasticsearch.ESClient.Search.WithContext(ctx),
/application/site/controller.go:77 (0xe9a8a4)
Search: data = GetES(ctx.Request.Context())
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/context.go:161 (0x987fda)
(*Context).Next: c.handlers[c.index](c)
/app/service/console/application/golang/console-api/application/auth/authenticate.go:16 (0xb90f7a)
APIKeyAuthenticate.func1: ctx.Next()
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/context.go:161 (0x987fda)
(*Context).Next: c.handlers[c.index](c)
/app/service/console/application/golang/console-api/application/error/error_handler.go:13 (0xb3c60e)
Handle500.func1: ctx.Next()
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/context.go:161 (0x987fda)
(*Context).Next: c.handlers[c.index](c)
/app/service/console/application/golang/console-api/application/error/error_handler.go:27 (0xb3c84f)
Handle400.func1: ctx.Next()
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/context.go:161 (0x987fda)
(*Context).Next: c.handlers[c.index](c)
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/recovery.go:83 (0x99bad3)
RecoveryWithWriter.func1: c.Next()
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/context.go:161 (0x987fda)
(*Context).Next: c.handlers[c.index](c)
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/logger.go:241 (0x99ac00)
LoggerWithConfig.func1: c.Next()
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/context.go:161 (0x987fda)
(*Context).Next: c.handlers[c.index](c)
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/gin.go:409 (0x991f1c)
(*Engine).handleHTTPRequest: c.Next()
/go/pkg/mod/github.com/gin-gonic/gin@v1.6.3/gin.go:367 (0x99161d)
(*Engine).ServeHTTP: engine.handleHTTPRequest(c)
/usr/local/go/src/net/http/server.go:2802 (0x6dc303)
serverHandler.ServeHTTP: handler.ServeHTTP(rw, req)
/usr/local/go/src/net/http/server.go:1890 (0x6d7ba4)
(*conn).serve: serverHandler{c.server}.ServeHTTP(w, w.req)
/usr/local/go/src/runtime/asm_amd64.s:1357 (0x45d300)
goexit: BYTE $0x90 // NOP
我也试着用 ctx *gin.Context
在 GetES
功能
func GetES(ctx *gin.Context) bool {
或设置 context.Background()
在es的搜索方法中:
elasticsearch.ESClient.Search.WithContext(context.Background()),
还是有错误。
如何使用 gin
与 go-elasticsearch
以及合适的 Context
类型?
这个方法需要什么内容?
https://github.com/elastic/go-elasticsearch/blob/master/_examples/main.go#l127
暂无答案!
目前还没有任何答案,快来回答吧!