"实现弹性搜索与 Logrus 日志记录集成"

下载万磁搜索绿色版

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是Golang学习者，那么本文《"实现弹性搜索与 Logrus 日志记录集成"》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

我正在使用 logrus 来记录我的 golang 应用程序。不过，我还想将其与 elastic search 集成，这样当我创建 logrus 日志条目时，所有日志也会刷新到 elastic search。目前，所有日志都创建在一个文件中，如下面的代码片段所示。我如何与弹性搜索集成？

type loggerconfig struct {
    filename string `validate:regexp=.log$`
    appname  string `validate:regexp=^[a-za-z]$`
}  

type applogger struct {
    err    error
    logger logrus.entry
}

func logger(loggerconfig loggerconfig) applogger {
    response := new(applogger)
    // validate the schema of the logger_config
    if errs := validator.validate(loggerconfig); errs != nil {
        response.err = errs
        // this sets up the error on the the response struct
    }

    logrus.setformatter(&logrus.jsonformatter{})
    f, err := os.openfile(loggerconfig.filename, os.o_wronly|os.o_create, 0755)
    if err != nil {
        response.err = err
    }
    multiplewriter := io.multiwriter(os.stdout, f)
    logrus.setoutput(multiplewriter)

    contextlogger := logrus.withfields(logrus.fields{
        "app": loggerconfig.appname,
    })


    //logrus.addhook(hook)
    response.logger = *contextlogger

    //response.logger.info("adele")
    return *response

}

我尝试过 elogrus 它添加了一个钩子，但我不知道如何使用它。这是尝试创建弹性搜索客户端的方法。我如何将其与 logrus 实例集成？

func prepareElasticSearchClient() *elastic.Client {
    indexName := "my-server"

    client, _ := elastic.NewClientFromConfig(&config.Config{
        URL:      os.Getenv("ELASTIC_SEARCH_URL_LOGS") + ":" + os.Getenv("ELASTIC_SEARCH_PORT_LOGS"),
        Index:    indexName,
        Username: os.Getenv("ELASTIC_SEARCH_USERNAME_LOGS"),
        Password: os.Getenv("ELASTIC_SEARCH_PASSWORD_LOGS"),
    })

    return client
}

之前我使用过像 winston 这样的模块，在其中设置弹性搜索日志记录非常容易，但不知何故，我发现很少有关于如何将 golang 日志记录与弹性搜索集成的 golang 文档

解决方案

使用 elogrus，您首先创建弹性客户端，并在使用 elogrus.newasyncelastichook() 创建它时将其传递给 elogrus 挂钩。 hook 只是包装发送消息到 elastic。然后将此挂钩添加到 logrus log。每次您使用 log 记录消息时，它都会触发您的钩子并将消息（如果日志级别过滤器通过）发送到 elastic。

log := logrus.New()
client, err := elastic.NewClient(elastic.SetURL("http://localhost:9200"))
// ... handle err
hook, err := elogrus.NewAsyncElasticHook(client, "localhost", logrus.DebugLevel, "testlog")
// ... handle err
log.Hooks.Add(hook)

newasyncelastichook 的签名为 (client *elastic.client, 主机字符串, 级别 logrus.level, 索引字符串) 其中：

• client 是指向您在使用 elastic 之前获取的 elastic.client 的指针
• host 是字符串，表示您从哪个主机发送日志跟踪（它是一个字符串 - 运行日志程序的主机的主机名）
• level 是您希望发送消息的最大 logrus 日志级别（例如，如果您想在本地查看 debug 消息，但只将 error 及以下消息发送到 elastic）
• index 是您想要添加来自 log 的消息的 elastic search 索引的名称

从这里您可以像使用 logrus 一样正常使用 log，并且所有消息都将传递到 elastic。

问题的另一部分有点棘手，并且根源于（不仅）golang elastic 客户端节点嗅探行为。我们在聊天中对其进行了调试，并将摘要发布为我对op的另一个相关问题的回答：Cannot connect to elastic search : no active connection found: no Elasticsearch node available

本篇关于《"实现弹性搜索与 Logrus 日志记录集成"》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！