这篇文章主要讲解了“怎么用Fluentd进行简单流处理”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“怎么用Fluentd进行简单流处理”吧!
成都创新互联公司专注于河东网站建设服务及定制,我们拥有丰富的企业做网站经验。 热诚为您提供河东营销型网站建设,河东网站制作、河东网页设计、河东网站官网定制、成都小程序开发服务,打造河东网络公司原创品牌,更为您提供河东网站排名全网营销落地服务。
在某些日志采集场景中,我们需要对数据流进行一些转换。比如,我们可能需要从日志记录中提取某些字段以进行错误告警,或向日志记录中插入新的字段用以后续的分析。
本文简单介绍一下使用Fluentd进行数据操作的技术细节。
{ "host": "192.168.1.1", "method": "GET", "path": "/index.html", "code": 200, "size": 2344, "referer": null}
这其中的code字段表示用户请求状态,我们可能对状态为2xx的请求不太关心,这样就可以将这类事件过滤掉,专门处理用户请求可能发生的异常情况。
我们可以通过在Fluentd中增加如下<filter>配置来实现事件过滤。
<filter apache.**> @type grep <exclude> key code pattern ^2\d\d$ </exclude></filter>
使用grep过滤插件,通过key指定code字段为过滤字段,通过pattern匹配code值为2xx的事件,将这些事件排除(exclude)掉。
filter_grep还可以对多个字段进行过滤。比如,保留状态码为5xx的事件,但过滤掉url中以/test/开头的请求。如下所示:
<filter apache.**> @type grep <regexp> key code pattern ^5\d\d$ </regexp> <exclude> key path pattern ^/test/ </exclude></filter>
<filter apache.**> @type record_transformer <record> server "${hostname}" </record></filter>
这里,record_transformer插件向事件record中插入了一个server字段,其值为web服务器的主机名。新的日志record就更新为如下格式:
{ "host": "192.168.1.1", "method": "GET", "path": "/index.html", "code": 200, "size": 2344, "referer": null, "server": "app1"}
filter_record_transformer除了可以直接插入预定义的一些变量,如${hostname},还可以插入其他变量或者使用ruby表达式来计算字段值。具体可参考此插件的使用说明,我们也会在后续的插件系列中进行介绍。
感谢各位的阅读,以上就是“怎么用Fluentd进行简单流处理”的内容了,经过本文的学习后,相信大家对怎么用Fluentd进行简单流处理这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!
网页名称:怎么用Fluentd进行简单流处理
分享网址:https://www.cdcxhl.com/article2/pjjooc.html
成都网站建设公司_创新互联,为您提供虚拟主机、云服务器、网站改版、定制开发、网站策划、网站建设
声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联