ElasticSearch

简介

flusher_elasticsearch flusher插件可以实现将采集到的数据,经过处理后,发送到 ElasticSearch,需要 ElasticSearch 版本至少为 8

版本

Alpha

配置参数

参数类型是否必选说明

Type

String

插件类型,固定为flusher_elasticsearch

Addresses

String数组

ElasticSearch 地址

Convert

Struct

ilogtail数据转换协议配置

Convert.Protocol

String

ilogtail数据转换协议,kafka flusher 可选值:custom_single,otlp_log_v1。默认值:custom_single

Convert.Encoding

String

ilogtail flusher数据转换编码,可选值:jsonnoneprotobuf,默认值:json

Convert.TagFieldsRename

Map

对日志中tags中的json字段重命名

Convert.ProtocolFieldsRename

Map

ilogtail日志协议字段重命名,可当前可重命名的字段:contents,tagstime

Index

String

插入数据目标索引

Authentication

Struct

ElasticSearch 连接访问认证配置

Authentication.PlainText.Username

String

ElasticSearch 用户名

Authentication.PlainText.Password

String

ElasticSearch 密码

Authentication.TLS.Enabled

Boolean

是否启用 TLS 安全连接,

Authentication.TLS.CAFile

String

TLS CA 根证书文件路径

Authentication.TLS.CertFile

String

TLS 连接证书文件路径

Authentication.TLS.KeyFile

String

TLS 连接私钥文件路径

Authentication.TLS.MinVersion

String

TLS 支持协议最小版本,可选配置:1.0, 1.1, 1.2, 1.3,默认:1.2

Authentication.TLS.MaxVersion

String

TLS 支持协议最大版本,可选配置:1.0, 1.1, 1.2, 1.3,默认采用:crypto/tls支持的版本,当前1.3

HTTPConfig.MaxIdleConnsPerHost

Int

每个host的连接池最大空闲连接数

HTTPConfig.ResponseHeaderTimeout

String

读取头部的时间限制,可选配置NanosecondMicrosecondMillisecondSecondMinuteHour

样例

采集/home/test-log/路径下的所有文件名匹配*.log规则的文件,并将采集结果发送到 ElasticSearch。

enable: true
inputs:
  - Type: file_log
    LogPath: /home/test_log
    FilePattern: "*.log"
flushers:
  - Type: flusher_elasticsearch
    Addresses: 
      - 192.XX.XX.1:9092
      - 192.XX.XX.2:9092
    Index: default
    Authentication:
      PlainText:
        Username: user
        Password: 123456

Last updated