go中es（olivere/elastic/v7）增加日志
如何给es增加日志
最常见的做法是：使用标准库的 log.Logger 作为 Logger 实现（它天然支持 Printf 方法），并通过 SetTraceLog 传入，即可开启跟踪日志，打印包括 DSL 在内的完整 HTTP 请求细节。
代码示例如下：
package mainimport ("context""log""os""github.com/olivere/elastic/v7"
)func main() {// 1. 创建一个 Logger 实例（使用标准库的 log.Logger，输出到控制台）// 配置日志前缀和标志（如时间、文件名等）traceLogger := log.New(os.Stdout, "[ES-TRACE] ", log.Ldate|log.Ltime|log.Lshortfile)// 2. 初始化 ES 客户端，通过 SetTraceLog 传入上面的 loggeresClient, err := elastic.NewClient(elastic.SetURL("http://localhost:9200"), // ES 服务地址elastic.SetSniff(false), // 本地环境建议关闭 sniffelastic.SetTraceLog(traceLogger), // 关键：开启跟踪日志，使用自定义 logger// 若有认证，添加：// elastic.SetBasicAuth("elastic", "changeme"),)if err != nil {log.Fatalf("创建 ES 客户端失败: %v", err)}// 3. 执行一个查询（测试跟踪日志）ctx := context.Background()query := elastic.NewMatchQuery("TITLE", "人工智能") // 示例查询// 执行搜索_, err = esClient.Search().Index("example_index"). // 替换为你的索引名Query(query).Size(10).Do(ctx)if err != nil {log.Printf("查询失败: %v", err)return}
}
以上代码效果说明
开启 SetTraceLog 后，客户端会将与 ES 的每一次 HTTP 交互（包括请求方法、URL、请求体 DSL、响应状态等）通过 Logger.Printf 输出。例如
[ES-TRACE] 2023/10/05 15:30:00 main.go:28: POST http://localhost:9200/example_index/_search?size=10
[ES-TRACE] 2023/10/05 15:30:00 main.go:28: Request: {"query":{"match":{"TITLE":{"query":"人工智能"}}}}
[ES-TRACE] 2023/10/05 15:30:00 main.go:28: Response: status=200, body={"took":3,"timed_out":false,"_shards":{"total":1,"successful":1,"skipped":0,"failed":0},"hits":{"total":{"value":2,"relation":"eq"},"max_score":0.87546873,"hits":[...]}}
其中：
• Request: 后面的内容就是完整的 ES 查询 DSL（与 REST API 请求体完全一致）。
• 还会输出请求 URL、响应状态码、响应体等信息，方便调试。
自定义日志
如果需要更灵活的日志格式（如 JSON 格式、脱敏敏感信息），可以自定义实现 elastic.Logger 接口：
// 自定义 Logger
type MyTraceLogger struct {// 可以添加自定义字段，如日志级别、输出目的地等
}// 实现 Printf 方法，满足 elastic.Logger 接口
func (l *MyTraceLogger) Printf(format string, v ...interface{}) {// 自定义日志输出逻辑，例如：// 1. 格式化日志// 2. 脱敏请求体中的敏感字段// 3. 输出到文件或第三方日志系统log.Printf("[自定义ES跟踪] "+format, v...)
}// 使用自定义 Logger
func main() {customLogger := &MyTraceLogger{}esClient, err := elastic.NewClient(elastic.SetURL("http://localhost:9200"),elastic.SetTraceLog(customLogger), // 传入自定义 logger)// ...
}
SetTraceLog 的正确用法是传入一个实现了 elastic.Logger 接口的对象（如标准库 log.Logger 或自定义 logger）。通过这种方式，客户端会自动将包括 DSL 在内的 HTTP 通信细节输出到日志中，效果类似 GORM 的 Debug()，是调试 ES 查询的高效手段。