应用平台 APPSTAGE-算子清洗功能介绍:功能说明
功能说明
Filebeat是一个轻量级的采集器,用于采集和处理,转发日志数据。Filebeat将作为代理安装在您的服务器上,监控您指定的日志文件或位置,收集日志事件,并将它们转发到kafka,推送到下一个处理点。
processors是filebeat定义了一系列对单条日志操作的方法,目前支持三类操作:
- 减少导出字段的数量
- 使用附加元数据增加字段
- 执行额外的处理或解码
每个processor接受一个事件(单条日志),将用户定义的操作应用于该事件并返回。如果您定义了一个处理器列表,它们将按照在filebeat配置文件中定义的顺序执行。任何一个算子执行失败,都会直接终止执行链条,并将异常事件发送到fail_to_topic,异常信息会记录在事件中的@errMsg中。