hadoop - 从水槽代理调用 shell 脚本

Question

我想从 flume agent machine 调用一个 shell 脚本。是否可以使用 flume 调用 shell 脚本？如果是的话，我该怎么做？

Answer 1

要扩展@Chris White 的评论：

如果要将脚本用作源，请使用 Exec Source。

如果您想将其用作拦截器，则可以编写自定义拦截器。但是，性能会很差，因为您将为每条消息（或者可能是批处理）启动一个新进程。我会推荐一个自定义的 Java 拦截器。