Commit 1d6ec0c4 authored by 谢宇轩's avatar 谢宇轩 😅

修改了一些插件的规则,j减少无用的输出

parent 4decf249
......@@ -176,8 +176,7 @@ func MatedateSender(ctx context.Context, esClient *elastic.Client) {
for {
select {
case m := <-messages:
log.Printf("created message : %s : \n", m.Index)
log.Println(m.data)
indexRequest := elastic.NewBulkIndexRequest().Index(m.Index).Doc(m.data)
bulkRequest.Add(indexRequest)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment