如何使用杜松子酒和去ElasticSearch?

70gysomp  于 2021-06-13  发布在  ElasticSearch
关注(0)|答案(0)|浏览(212)

使用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.ContextGetES 功能

func GetES(ctx *gin.Context) bool {

或设置 context.Background() 在es的搜索方法中:

elasticsearch.ESClient.Search.WithContext(context.Background()),

还是有错误。
如何使用 gingo-elasticsearch 以及合适的 Context 类型?
这个方法需要什么内容?
https://github.com/elastic/go-elasticsearch/blob/master/_examples/main.go#l127

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题