Fluentd路由的示例分析

這篇文章主要為大家展示了“Fluentd路由的示例分析”，內容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領大家一起研究并學習一下“Fluentd路由的示例分析”這篇文章吧。

1. 簡單場景：單輸入->過濾器->輸出

   
   

   <source>  @type forward</source>
   <filter app.**>  @type record_transformer  <record>    hostname "#{Socket.gethostname}"  </record></filter>
   <match app.**>  @type file  # ...</match>

    

   forward接收tcp消息，record_transformer給日志增加一個hostname字段，輸出到file

   
   

2. 兩個輸入

   <source>  @type forward</source>
   <source>  @type tail  tag system.logs  # ...</source>
   <filter app.**>  @type record_transformer  <record>    hostname "#{Socket.gethostname}"  </record></filter>
   <match {app.**,system.logs}>  @type file  # ...</match>

    

   較上一個示例，增加了一個tail輸入，tail產生的事件直接寫文件。
   

   
   

3. 輸入->過濾器->帶標簽的輸出

   <source>  @type forward</source>
   <source>  @type dstat  @label @METRICS # dstat events are routed to <label @METRICS>  # ...</source>
   <filter app.**>  @type record_transformer  <record>    # ...  </record></filter>
   <match app.**>  @type file  # ...</match>
   <label @METRICS>  <match **>    @type elasticsearch    # ...  </match></label>

    

   forward產生的事件處理流程不變，dstat直接跳轉至@METRICS指定的label，寫入elasticsearch

   
   

4. 改寫tag重新路由

   <match worker.**>  @type route  remove_tag_prefix worker  add_tag_prefix metrics.event
     <route **>    copy # For fall-through. Without copy, routing is stopped here.   </route>  <route **>    copy    @label @BACKUP  </route></match>
   <match metrics.event.**>  @type stdout</match>
   <label @BACKUP>  <match metrics.event.**>    @type file    path /var/log/fluent/backup  </match></label>

    

   route插件將worker標記的事件重新標記為metrics.event，并重新發送事件給路由引擎，事件進入兩個處理分支：輸出到stdout；寫入file
   

   
   

   
   

5. 根據record內容重新路由

   <source>  @type forward</source>
   # event example: app.logs {"message":"[info]: ..."}<match app.**>  @type rewrite_tag_filter  <rule>    key message    pattern ^\[(\w+)\]    tag $1.${tag}  </rule>  # you can put more <rule></match>
   # send mail when receives alert level logs<match alert.app.**>  @type mail  # ...</match>
   # other logs are stored into file<match *.app.**>  @type file  # ...</match>

    

   forward產生的事件由rewrite_tag_filter處理，提取record中的[log_level]，添加到原tag之前，生成新的tag。事件再次進入路由引擎，alert開頭的tag標記的事件，通過mail處理；其他類型的事件寫入file
   

   
   

6. 重新路由到指定label

   <source>  @type forward</source>
   <match app.**>  @type copy  <store>    @type forward    # ...  </store>  <store>    @type relabel    @label @NOTIFICATION  </store></match>
   <label @NOTIFICATION>  <filter app.**>    @type grep    regexp1 message ERROR  </filter>
     <match app.**>    @type mail  </match></label>

    

以上是“Fluentd路由的示例分析”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！