Logstash,Fluentd, Logtail对比伤害

叁歲伎倆 2022-02-15 06:27 204阅读 0赞

# [Logstash,Fluentd, Logtail对比伤害][Logstash_Fluentd_ Logtail] #

#  摘要： 针对主流日志采集客户端（Logstash，Fluentd，以及日志服务客户端Logtail）进行功能、性能和稳定性测评 #

# 日志收集的场景 #

DT时代，数以亿万计的服务器、移动终端、网络设备每天产生海量的日志。

中心化的日志处理方案有效地解决了在完整生命周期内对日志的消费需求，而日志从设备采集上云是始于足下的第一步。

[![logtail\_centralize\_arch][logtail_centralize_arch]][logtail_centralize_arch]

# 三款日志收集工具 #

### logstash ###

开源界鼎鼎大名ELK stack中的"L"，社区活跃，生态圈提供大量插件支持。

logstash基于JRuby实现，可以跨平台运行在JVM上。

模块化设计，有很强的扩展性和互操作性。

### fluentd ###

开源社区中流行的日志收集工具，td-agent是其商业化版本，由Treasure Data公司维护，是本文选用的评测版本。

fluentd基于CRuby实现，并对性能表现关键的一些组件用C语言重新实现，整体性能不错。

fluentd设计简洁，pipeline内数据传递可靠性高。相较于logstash，其插件支持相对少一些。

### logtail ###

阿里云日志服务的生产者，目前在阿里集团内部机器上运行，经过3年多时间的考验，目前为阿里公有云用户提供日志收集服务。

采用C++语言实现，对稳定性、资源控制、管理等下过很大的功夫，性能良好。相比于logstash、fluentd的社区支持，logtail功能较为单一，专注日志收集功能。

# 日志文件收集场景 - 功能对比 #

<table> 
 <thead> 
  <tr> 
   <th>功能项</th> 
   <th>logstash</th> 
   <th>fluentd</th> 
   <th>logtail</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>日志读取</td> 
   <td>轮询</td> 
   <td>轮询</td> 
   <td>事件触发</td> 
  </tr> 
  <tr> 
   <td>文件轮转</td> 
   <td>支持</td> 
   <td>支持</td> 
   <td>支持</td> 
  </tr> 
  <tr> 
   <td>Failover处理 (本地checkpoint)</td> 
   <td>支持</td> 
   <td>支持</td> 
   <td>支持</td> 
  </tr> 
  <tr> 
   <td>通用日志解析</td> 
   <td>支持grok（基于正则表达式）解析</td> 
   <td>支持正则表达式解析</td> 
   <td>支持正则表达式解析</td> 
  </tr> 
  <tr> 
   <td>特定日志类型</td> 
   <td>支持delimiter、key-value、json等主流格式</td> 
   <td>支持delimiter、key-value、json等主流格式</td> 
   <td>支持key-value格式</td> 
  </tr> 
  <tr> 
   <td>数据发送压缩</td> 
   <td>插件支持</td> 
   <td>插件支持</td> 
   <td>LZ4</td> 
  </tr> 
  <tr> 
   <td>数据过滤</td> 
   <td>支持</td> 
   <td>支持</td> 
   <td>支持</td> 
  </tr> 
  <tr> 
   <td>数据buffer发送</td> 
   <td>插件支持</td> 
   <td>插件支持</td> 
   <td>支持</td> 
  </tr> 
  <tr> 
   <td>发送异常处理</td> 
   <td>插件支持</td> 
   <td>插件支持</td> 
   <td>支持</td> 
  </tr> 
  <tr> 
   <td>运行环境</td> 
   <td>JRuby实现，依赖JVM环境</td> 
   <td>CRuby、C实现，依赖Ruby环境</td> 
   <td>C++实现，无特殊要求</td> 
  </tr> 
  <tr> 
   <td>线程支持</td> 
   <td>支持多线程</td> 
   <td>多线程受GIL限制</td> 
   <td>支持多线程</td> 
  </tr> 
  <tr> 
   <td>热升级</td> 
   <td>不支持</td> 
   <td>不支持</td> 
   <td>支持</td> 
  </tr> 
  <tr> 
   <td>中心化配置管理</td> 
   <td>不支持</td> 
   <td>不支持</td> 
   <td>支持</td> 
  </tr> 
  <tr> 
   <td>运行状态自检</td> 
   <td>不支持</td> 
   <td>不支持</td> 
   <td>支持cpu/内存阈值保护</td> 
  </tr> 
 </tbody> 
</table>

# 日志文件收集场景 - 性能对比 #

### 日志样例 ###

以Nginx的access log为样例，如下一条日志365字节，结构化成14个字段：

[![logtail\_nginx\_access\_log][logtail_nginx_access_log]][logtail_nginx_access_log]

在接下来的测试中，将模拟不同的压力将该日志重复写入文件，每条日志的time字段取当前系统时间，其它13个字段相同。

相比于实际场景，模拟场景在日志解析上并无差异，有一点区别是：较高的数据压缩率会减少网络写出流量。

### logstash ###

logstash-2.0.0版本，通过grok解析日志并写出到kafka（内置插件，开启gzip压缩）。

日志解析配置：

1.   
    
    grok \{
2.   
    
    patterns\_dir=> "/home/admin/workspace/survey/logstash/patterns"
3.   
    
    match=>\{ "message"=>"%\{IPORHOST:ip\} %\{USERNAME:rt\} - \\\[%\{HTTPDATE:time\}\\\] \\"%\{WORD:method\} %\{DATA:url\}\\" %\{NUMBER:status\} %\{NUMBER:size\} \\"%\{DATA:ref\}\\" \\"%\{DATA:agent\}\\" \\"%\{DATA:cookie\_unb\}\\" \\"%\{DATA:cookie\_cookie2\}\\" \\"%\{DATA:monitor\_traceid\}\\" %\{WORD:cell\} %\{WORD:ups\} %\{BASE10NUM:remote\_port\}" \}
4.   
    
    remove\_field=>\[ "message"\]
5.   
    
    \}

测试结果：

<table> 
 <thead> 
  <tr> 
   <th>写入TPS</th> 
   <th>写入流量 (KB/s)</th> 
   <th>CPU使用率 (%)</th> 
   <th>内存使用 (MB)</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>500</td> 
   <td>178.22</td> 
   <td>22.4</td> 
   <td>427</td> 
  </tr> 
  <tr> 
   <td>1000</td> 
   <td>356.45</td> 
   <td>46.6</td> 
   <td>431</td> 
  </tr> 
  <tr> 
   <td>5000</td> 
   <td>1782.23</td> 
   <td>221.1</td> 
   <td>440</td> 
  </tr> 
  <tr> 
   <td>10000</td> 
   <td>3564.45</td> 
   <td>483.7</td> 
   <td>450</td> 
  </tr> 
 </tbody> 
</table>

### fluentd ###

td-agent-2.2.1版本，通过正则表达式解析日志并写入kafka（第三方插件fluent-plugin-kafka，开启gzip压缩）。

日志解析配置：

1.   
    
    <source>
2.   
    
    type tail
3.   
    
    format /^(? <ip>\\S+)\\s(?<rt>\\d+)\\s-\\s\\\[(?<time>\[^\\\]\]\*)\\\]\\s"(?<url>\[^\\"\]+)"\\s(?<status>\\d+)\\s(?<size>\\d+)\\s"(?<ref>\[^\\"\]+)"\\s"(?<agent>\[^\\"\]+)"\\s"(?<cookie\_unb>\\d+)"\\s"(?<cookie\_cookie2>\\w+)"\\s"(?
4.   
    
    <monitor\_traceid>\\w+)"\\s(?<cell>\\w+)\\s(?<ups>\\w+)\\s(?<remote\_port>\\d+).\*$/
5.   
    
    time\_format %d/%b/%Y:%H:%M:%S %z
6.   
    
     path /home/admin/workspace/temp/mock\_log/access.log
7.   
    
     pos\_file /home/admin/workspace/temp/mock\_log/nginx\_access.pos
8.   
    
     tag nginx.access
9.   
    
    </source>
10.

测试结果：

<table> 
 <thead> 
  <tr> 
   <th>写入TPS</th> 
   <th>写入流量 (KB/s)</th> 
   <th>CPU使用率 (%)</th> 
   <th>内存使用 (MB)</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>500</td> 
   <td>178.22</td> 
   <td>13.5</td> 
   <td>61</td> 
  </tr> 
  <tr> 
   <td>1000</td> 
   <td>356.45</td> 
   <td>23.4</td> 
   <td>61</td> 
  </tr> 
  <tr> 
   <td>5000</td> 
   <td>1782.23</td> 
   <td>94.3</td> 
   <td>103</td> 
  </tr> 
 </tbody> 
</table>

注：受GIL限制，fluentd单进程最多使用1个cpu核心，可以使用插件multiprocess以多进程的形式支持更大的日志吞吐。

### logtail ###

logtail 0.9.4版本，设置正则表达式进行日志结构化，数据LZ4压缩后以HTTP协议写到阿里云日志服务，设置batch\_size为4000条。

日志解析配置：

1.   
    
    logRegex : ( \\S+)\\s(\\d+)\\s-\\s\\\[(\[^\]\]+)\]\\s"(\[^"\]+)"\\s(\\d\+)\\s(\\d\+)\\s"(\[^"\]+)"\\s"(\[^"\]+)"\\s"(\\d+)"\\s"(\\w+)"\\s"(\\w+)"\\s(\\w\+)\\s(\\w\+)\\s(\\d\+).\*
2.   
    
    keys : ip,rt,time,url,status,size,ref,agent,cookie\_unb,cookie\_cookie2,monitor\_traceid,cell,ups,remote\_port
3.   
    
    timeformat : %d/%b/%Y:%H:%M:%S
4.

测试结果：

<table> 
 <thead> 
  <tr> 
   <th>写入TPS</th> 
   <th>写入流量 (KB/s)</th> 
   <th>CPU使用率 (%)</th> 
   <th>内存使用 (MB)</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>500</td> 
   <td>178.22</td> 
   <td>1.7</td> 
   <td>13</td> 
  </tr> 
  <tr> 
   <td>1000</td> 
   <td>356.45</td> 
   <td>3</td> 
   <td>15</td> 
  </tr> 
  <tr> 
   <td>5000</td> 
   <td>1782.23</td> 
   <td>15.3</td> 
   <td>23</td> 
  </tr> 
  <tr> 
   <td>10000</td> 
   <td>3564.45</td> 
   <td>31.6</td> 
   <td>25</td> 
  </tr> 
 </tbody> 
</table>

### 单核处理能力对比 ###

[![logtail\_performance\_evaluation][logtail_performance_evaluation]][logtail_performance_evaluation]

# 总结 #

可以看到三款日志工具各有特点：

*  logstash支持所有主流日志类型，插件支持最丰富，可以灵活DIY，但性能较差，JVM容易导致内存使用量高。
 *  fluentd支持所有主流日志类型，插件支持较多，性能表现较好。
 *  logtail占用机器cpu、内存资源最少，结合阿里云日志服务的E2E体验良好，但目前对特定日志类型解析的支持较弱，后续需要把这一块补起来。

posted @ 2019-04-23 10:59 [疯狂的米粒儿][Link 1] 阅读( ...) 评论( ...) [编辑][Link 2] 收藏

[Logstash_Fluentd_ Logtail]: https://www.cnblogs.com/Su-per-man/p/10755126.html
[logtail_centralize_arch]: /images/20220215/cee2fb1c295f44d0a833a8d4b500a68a.png
[logtail_nginx_access_log]: /images/20220215/af4d676fb91b461884fdd9d5f7fcfc86.png
[logtail_performance_evaluation]: /images/20220215/55c07ff6c4934ddbbc96f473eb18162c.png
[Link 1]: https://www.cnblogs.com/Su-per-man/
[Link 2]: https://i.cnblogs.com/EditPosts.aspx?postid=10755126