Flume中agent是干什么的,有什么作用

2020-06-05 11:23发布

4条回答
水默
2021-12-17 16:26

  Source将数据写入Channel ,先经过Channel处理器,Channel处理器将这些事件传到一个或多个Source配置的拦截器中。

  拦截器是一段代码,可以基于某些它完成的处理来读取事件和修改或删除事件。基于某些标准,如正则表达式,拦截器可以用来删除事件。一旦拦截器处理完事件,拦截器链返回的事件列表传递到Channel列表,即通过Channel 选择器为每个事件选择的Channel。

  (拦截器不能写太复杂的逻辑,影响效率)

  Source 可以通过处理器-拦截器-选择器路由写入多个 Channel。 Channel选择器是决定每个事件必须写入到Source 附带的哪个Channel的组件。因此拦截器可以用来插入或删除事件中的数据,这样Channel选择器可以应用一些条件在这些事件上,来决定事件必须写入哪些Channel。 Channel选择器可以对事件应用任意过滤条件,来决定每个事件必须写入哪些Channel ,以及Channel是必需的或可选的。


一周热门 更多>