Flume Python 中的拦截器
Flume interceptor in Python
我完全没有在 Java 工作的经验。
谁能告诉我是否有任何方法可以在 Python 中编写 flume 拦截器？
以下是其 Java 实现：
https://thisdataguy.com/2014/02/07/how-to-build-a-full-flume-interceptor-by-a-non-java-developer/
不，flume 没有 Python 拦截器或将数据流式传输到进程的概念，类似于 MapReduce Streaming 或 Spark Streaming。原因之一是 Flume 事件稍微复杂一点，它具有 headers 和 body 的概念。很难将您的活动流式传输到 Python
我完全没有在 Java 工作的经验。
谁能告诉我是否有任何方法可以在 Python 中编写 flume 拦截器？
以下是其 Java 实现： https://thisdataguy.com/2014/02/07/how-to-build-a-full-flume-interceptor-by-a-non-java-developer/
不，flume 没有 Python 拦截器或将数据流式传输到进程的概念，类似于 MapReduce Streaming 或 Spark Streaming。原因之一是 Flume 事件稍微复杂一点，它具有 headers 和 body 的概念。很难将您的活动流式传输到 Python