這篇文章主要為大家展示了“Fluentd路由的示例分析”,內(nèi)容簡而易懂,條理清晰,希望能夠幫助大家解決疑惑,下面讓小編帶領(lǐng)大家一起研究并學習一下“Fluentd路由的示例分析”這篇文章吧。
目前創(chuàng)新互聯(lián)已為上1000家的企業(yè)提供了網(wǎng)站建設、域名、雅安服務器托管、成都網(wǎng)站托管、企業(yè)網(wǎng)站設計、蔡家坡網(wǎng)站維護等服務,公司將堅持客戶導向、應用為本的策略,正道將秉承"和諧、參與、激情"的文化,與客戶和合作伙伴齊心協(xié)力一起成長,共同發(fā)展。
簡單場景:單輸入->過濾器->輸出
@type forward
@type record_transformer
hostname "#{Socket.gethostname}"
@type file
# ...
forward接收tcp消息,record_transformer給日志增加一個hostname字段,輸出到file
兩個輸入
@type forward
@type tail
tag system.logs
# ...
@type record_transformer
hostname "#{Socket.gethostname}"
@type file
# ...
較上一個示例,增加了一個tail輸入,tail產(chǎn)生的事件直接寫文件。
輸入->過濾器->帶標簽的輸出
@type forward
@type dstat
@label @METRICS # dstat events are routed to
# ...
@type record_transformer
# ...
@type file
# ...
@type elasticsearch
# ...
forward產(chǎn)生的事件處理流程不變,dstat直接跳轉(zhuǎn)至@METRICS指定的label,寫入elasticsearch
改寫tag重新路由
@type route
remove_tag_prefix worker
add_tag_prefix metrics.event
copy # For fall-through. Without copy, routing is stopped here.
copy
@label @BACKUP
@type stdout
@type file
path /var/log/fluent/backup
route插件將worker標記的事件重新標記為metrics.event,并重新發(fā)送事件給路由引擎,事件進入兩個處理分支:輸出到stdout;寫入file
根據(jù)record內(nèi)容重新路由
@type forward
# event example: app.logs {"message":"[info]: ..."}
@type rewrite_tag_filter
key message
pattern ^\[(\w+)\]
tag $1.${tag}
# you can put more
# send mail when receives alert level logs
@type mail
# ...
# other logs are stored into file
@type file
# ...
forward產(chǎn)生的事件由rewrite_tag_filter處理,提取record中的[log_level],添加到原tag之前,生成新的tag。事件再次進入路由引擎,alert開頭的tag標記的事件,通過mail處理;其他類型的事件寫入file
重新路由到指定label
@type forward
@type copy
@type forward
# ...
@type relabel
@label @NOTIFICATION
@type grep
regexp1 message ERROR
@type mail
以上是“Fluentd路由的示例分析”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對大家有所幫助,如果還想學習更多知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道!