logstash 輸出外掛程式之redis與es

2021-08-07 19:26:51 字數 3244 閱讀 4891

logstash - 輸出外掛程式之redis與es

第二章 logstash - 輸出外掛程式之redis與es

最常用的兩個輸出外掛程式:

redis

es一、redis

1、用法

複製**

1 output

20 }

複製**

2、配置項

以上所有配置項都是可選的,沒有必須的。(以下4個紅色配置是最重要的4個配置)

批處理類(僅用於data_type為list)

batch:設為true,通過傳送一條rpush命令,儲存一批的資料

預設為false:1條rpush命令,儲存1條資料

設為true之後,1條rpush會傳送batch_events條資料或傳送batch_timeout秒(取決於哪乙個先到達)

batch_events:一次rpush多少條

預設50條

batch_timeout:一次rpush最多消耗多少s

預設5s

編碼類codec:對輸出資料進行codec,避免使用logstash的separate filter

擁塞保護(僅用於data_type為list)

congestion_interval:每多長時間進行一次擁塞檢查

預設1s

設為0,表示對每rpush乙個,都進行檢測

congestion_threshold:list中最多可以存在多少個item資料

預設是0:表示禁用擁塞檢測

當list中的資料量達到congestion_threshold,會阻塞直到有其他消費者消費list中的資料

作用:防止oom

data_type

list:使用rpush

channel:使用publish

db:使用redis的資料庫,預設使用0號

host:陣列

eg.["127.0.0.1:6380", "127.0.0.1"]

可以指定port,會覆蓋全域性port

port:全域性port,預設6379

key:list或channel的名字

支援動態key,例如:logstash-%

password:redis密碼,預設不使用密碼

reconnect_interval:失敗重連的間隔,預設為1s

timeout:連線超時,預設5s

二、es

1、使用方式

複製**

1 output

13         keystore => /***

14         keystore_password => ***

15         manage_template => true

16         max_retries => 3

17         parent => nil

18         password => ***

19         path => /

20         proxy => ***

21         retry_max_interval => 2

22         routing => ***

23         script => ***

24         script_lang => ***

25         script_type => inline

26         script_var_name => event

27         scripted_upsert => false

28         sniffing => false

29         sniffing_delay => 5

30         ssl => false

31         ssl_certificate_verification => true

32         template => /***

33         template_name => logstash

34         template_overwrite => false

35         timeout => 5

36         truststore => /***

37         truststore_password => ***

38         upsert => ***

39         user => ***

40         workers => 1

41     }

42 }

複製**

2、基本配置

以上配置全部都是可選的,沒有必須的。以下列出最重要的幾個。

hosts:["127.0.0.1:9200","127.0.0.2:9200"]

action:指定es的行為,index, delete, create, update

預設為index:index a document(該document就是乙個來自於logstash的event)

delete:通過id刪除乙個document(需要指定document_id)

create:index a document(如果該document已經在index中存在,則失敗)

update:通過id更新乙個document

cacert:驗證server合法性的.cer或.pem檔案路徑

codec:

document_id

document_type

index:預設值:logstash-%

便於刪除老資料

在語法解析的時候,看到+號開頭的,會自動認為後面是時間格式,嘗試用時間格式來解析後續字串。所以,之前處理過程中不要給自定義的字段起乙個+號開頭的名字

索引名中不能有大寫字母

有時也會自定義為:logstash-%-%

user:進入es cluster的使用者

password:進入es cluster的密碼

timeout:set the timeout for network operations and requests sent elasticsearch. if a timeout occurs, the request will be retried.

flush_size:預設500,logstash攢夠500條資料再一次性向es傳送

idle_flush_time:預設1s,如果1s內沒攢夠500條還是會一次性將攢的資料發出去給es

Logstash常用外掛程式

logstash外掛程式 常用的流行外掛程式 input 外掛程式 filters 外掛程式 output 外掛程式 input 外掛程式 流行的logstash輸入外掛程式 file 檔案流 檔案輸入外掛程式從輸入的內容中流事件,每個事件都被假定為單行。它會自動檢測到旋轉的旋轉並處理它。它保留了讀...

Logstash 外掛程式安裝

官方的安裝指令是 1 bin plugininstalllogstash output webhdfs 但是往往安裝不成功,一般就是如下情況,然後卡著不動了 validating logstash output webhdfs 原因是防火牆擋掉了logstash的預設gem source 1 2 c...

logstash安裝外掛程式

logstash預設沒有安裝logstash output syslog元件,如需實現syslog輸出,需要安裝此外掛程式後才能進行,操作方法如下 1,檢視當前元件安裝情況 opt logstash bin logstash plugin list 如果能訪問公網,可使用此方法,命令格式如下 opt...